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

- update service

Browse Source
master
李光春 2 years ago
parent c462f1502c
commit e07a968ad0
47 changed files with 315 additions and 316 deletions
Show Stats Download Patch File Download Diff File

16
service/eastiot/pgsql.go
Unescape View File

@ -2,18 +2,18 @@ package eastiot
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Record(golog2.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部
@ -21,6 +21,6 @@ func (app *App) postgresqlLog(request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: request.ResponseBody, //【返回】内容 ResponseBody: request.ResponseBody, //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

16
service/ejiaofei/pgsql.go
Unescape View File

@ -2,19 +2,19 @@ package ejiaofei
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
"go.dtapp.net/library/utils/gomongo" "go.dtapp.net/library/utils/gomongo"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Record(golog2.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部
@ -22,6 +22,6 @@ func (app *App) postgresqlLog(request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: datatypes.JSON(gojson.JsonEncodeNoError(gomongo.XmlDecodeNoError(request.ResponseBody))), //【返回】内容 ResponseBody: datatypes.JSON(gojson.JsonEncodeNoError(gomongo.XmlDecodeNoError(request.ResponseBody))), //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

16
service/feishu/pgsql.go
Unescape View File

@ -2,18 +2,18 @@ package feishu
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Record(golog2.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部
@ -21,6 +21,6 @@ func (app *App) postgresqlLog(request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: request.ResponseBody, //【返回】内容 ResponseBody: request.ResponseBody, //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

14
service/jd/pgsql.go
Unescape View File

@ -2,17 +2,17 @@ package jd
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(api string, request gorequest2.Response) { func (app *App) postgresqlLog(api string, request gorequest.Response) {
app.log.Record(golog2.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: api, //【请求】接口 RequestApi: api, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
@ -21,6 +21,6 @@ func (app *App) postgresqlLog(api string, request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: request.ResponseBody, //【返回】内容 ResponseBody: request.ResponseBody, //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

16
service/kashangwl/pgsql.go
Unescape View File

@ -2,18 +2,18 @@ package kashangwl
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Record(golog2.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部
@ -21,6 +21,6 @@ func (app *App) postgresqlLog(request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: request.ResponseBody, //【返回】内容 ResponseBody: request.ResponseBody, //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

12
service/kuaishou/mongo.go
Unescape View File

@ -2,7 +2,7 @@ package kuaishou
import ( import (
"go.dtapp.net/library/utils/gomongo" "go.dtapp.net/library/utils/gomongo"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
) )
@ -13,8 +13,8 @@ type mongoZap struct {
RequestUrl string `json:"request_url" bson:"request_url"` //【请求】链接 RequestUrl string `json:"request_url" bson:"request_url"` //【请求】链接
RequestApi string `json:"request_api" bson:"request_api"` //【请求】接口 RequestApi string `json:"request_api" bson:"request_api"` //【请求】接口
RequestMethod string `json:"request_method" bson:"request_method"` //【请求】方式 RequestMethod string `json:"request_method" bson:"request_method"` //【请求】方式
RequestParams gorequest2.Params `json:"request_params" bson:"request_params"` //【请求】参数 RequestParams gorequest.Params `json:"request_params" bson:"request_params"` //【请求】参数
RequestHeader gorequest2.Headers `json:"request_header" bson:"request_header"` //【请求】头部 RequestHeader gorequest.Headers `json:"request_header" bson:"request_header"` //【请求】头部
ResponseHeader http.Header `json:"response_header" bson:"response_header"` //【返回】头部 ResponseHeader http.Header `json:"response_header" bson:"response_header"` //【返回】头部
ResponseStatusCode int `json:"response_status_code" bson:"response_status_code"` //【返回】状态码 ResponseStatusCode int `json:"response_status_code" bson:"response_status_code"` //【返回】状态码
ResponseBody map[string]interface{} `json:"response_body" bson:"response_body"` //【返回】内容 ResponseBody map[string]interface{} `json:"response_body" bson:"response_body"` //【返回】内容
@ -30,12 +30,12 @@ func (m *mongoZap) TableName() string {
return "kuaishou" return "kuaishou"
} }
func (app *App) mongoLog(request gorequest2.Response) { func (app *App) mongoLog(request gorequest.Response) {
_, _ = app.mongo.Model(&mongoZap{}).InsertOne(mongoZap{ _, _ = app.mongo.Model(&mongoZap{}).InsertOne(mongoZap{
RequestTime: gomongo.BsonTime(request.RequestTime), //【请求】时间 RequestTime: gomongo.BsonTime(request.RequestTime), //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: request.RequestParams, //【请求】参数 RequestParams: request.RequestParams, //【请求】参数
RequestHeader: request.RequestHeader, //【请求】头部 RequestHeader: request.RequestHeader, //【请求】头部

16
service/kuaishou/pgsql.go
Unescape View File

@ -2,18 +2,18 @@ package kuaishou
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Record(golog2.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部
@ -21,6 +21,6 @@ func (app *App) postgresqlLog(request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: request.ResponseBody, //【返回】内容 ResponseBody: request.ResponseBody, //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

12
service/leshuazf/mongo.go
Unescape View File

@ -2,7 +2,7 @@ package leshuazf
import ( import (
"go.dtapp.net/library/utils/gomongo" "go.dtapp.net/library/utils/gomongo"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
) )
@ -13,8 +13,8 @@ type mongoZap struct {
RequestUrl string `json:"request_url" bson:"request_url"` //【请求】链接 RequestUrl string `json:"request_url" bson:"request_url"` //【请求】链接
RequestApi string `json:"request_api" bson:"request_api"` //【请求】接口 RequestApi string `json:"request_api" bson:"request_api"` //【请求】接口
RequestMethod string `json:"request_method" bson:"request_method"` //【请求】方式 RequestMethod string `json:"request_method" bson:"request_method"` //【请求】方式
RequestParams gorequest2.Params `json:"request_params" bson:"request_params"` //【请求】参数 RequestParams gorequest.Params `json:"request_params" bson:"request_params"` //【请求】参数
RequestHeader gorequest2.Headers `json:"request_header" bson:"request_header"` //【请求】头部 RequestHeader gorequest.Headers `json:"request_header" bson:"request_header"` //【请求】头部
ResponseHeader http.Header `json:"response_header" bson:"response_header"` //【返回】头部 ResponseHeader http.Header `json:"response_header" bson:"response_header"` //【返回】头部
ResponseStatusCode int `json:"response_status_code" bson:"response_status_code"` //【返回】状态码 ResponseStatusCode int `json:"response_status_code" bson:"response_status_code"` //【返回】状态码
ResponseBody map[string]interface{} `json:"response_body" bson:"response_body"` //【返回】内容 ResponseBody map[string]interface{} `json:"response_body" bson:"response_body"` //【返回】内容
@ -30,12 +30,12 @@ func (m *mongoZap) TableName() string {
return "leshuazf" return "leshuazf"
} }
func (app *App) mongoLog(request gorequest2.Response) { func (app *App) mongoLog(request gorequest.Response) {
_, _ = app.mongo.Model(&mongoZap{}).InsertOne(mongoZap{ _, _ = app.mongo.Model(&mongoZap{}).InsertOne(mongoZap{
RequestTime: gomongo.BsonTime(request.RequestTime), //【请求】时间 RequestTime: gomongo.BsonTime(request.RequestTime), //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: request.RequestParams, //【请求】参数 RequestParams: request.RequestParams, //【请求】参数
RequestHeader: request.RequestHeader, //【请求】头部 RequestHeader: request.RequestHeader, //【请求】头部

8
service/leshuazf/pgsql.go
Unescape View File

@ -3,17 +3,17 @@ package leshuazf
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
"go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Api.Record(golog.ApiPostgresqlLog{ app.log.Api.Record(golog.ApiPostgresqlLog{
RequestTime: request.RequestTime, //【请求】时间 RequestTime: request.RequestTime, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部

10
service/meituan/api.generate_link.go
Unescape View File

@ -2,7 +2,7 @@ package meituan
import ( import (
"encoding/json" "encoding/json"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
) )
@ -15,11 +15,11 @@ type ApiGenerateLinkResponse struct {
type ApiGenerateLinkResult struct { type ApiGenerateLinkResult struct {
Result ApiGenerateLinkResponse // 结果 Result ApiGenerateLinkResponse // 结果
Body []byte // 内容 Body []byte // 内容
Http gorequest2.Response // 请求 Http gorequest.Response // 请求
Err error // 错误 Err error // 错误
} }
func NewApiGenerateLinkResult(result ApiGenerateLinkResponse, body []byte, http gorequest2.Response, err error) *ApiGenerateLinkResult { func NewApiGenerateLinkResult(result ApiGenerateLinkResponse, body []byte, http gorequest.Response, err error) *ApiGenerateLinkResult {
return &ApiGenerateLinkResult{Result: result, Body: body, Http: http, Err: err} return &ApiGenerateLinkResult{Result: result, Body: body, Http: http, Err: err}
} }
@ -27,14 +27,14 @@ func NewApiGenerateLinkResult(result ApiGenerateLinkResponse, body []byte, http
// https://union.meituan.com/v2/apiDetail?id=25 // https://union.meituan.com/v2/apiDetail?id=25
func (app *App) ApiGenerateLink(actId int64, sid string, linkType, shortLink int) *ApiGenerateLinkResult { func (app *App) ApiGenerateLink(actId int64, sid string, linkType, shortLink int) *ApiGenerateLinkResult {
// 参数 // 参数
param := gorequest2.NewParams() param := gorequest.NewParams()
param.Set("actId", actId) // 活动id，可以在联盟活动列表中查看获取 param.Set("actId", actId) // 活动id，可以在联盟活动列表中查看获取
param.Set("appkey", app.appKey) // 媒体名称，可在推广者备案-媒体管理中查询 param.Set("appkey", app.appKey) // 媒体名称，可在推广者备案-媒体管理中查询
param.Set("sid", sid) // 推广位sid，支持通过接口自定义创建，不受平台200个上限限制，长度不能超过64个字符，支持小写字母和数字，历史已创建的推广位不受这个约束 param.Set("sid", sid) // 推广位sid，支持通过接口自定义创建，不受平台200个上限限制，长度不能超过64个字符，支持小写字母和数字，历史已创建的推广位不受这个约束
param.Set("linkType", linkType) // 投放链接的类型 param.Set("linkType", linkType) // 投放链接的类型
param.Set("shortLink", shortLink) // 获取长链还是短链 param.Set("shortLink", shortLink) // 获取长链还是短链
// 转换 // 转换
params := gorequest2.NewParamsWith(param) params := gorequest.NewParamsWith(param)
params["sign"] = app.getSign(app.secret, params) params["sign"] = app.getSign(app.secret, params)
// 请求 // 请求
request, err := app.request("https://openapi.meituan.com/api/generateLink", params, http.MethodGet) request, err := app.request("https://openapi.meituan.com/api/generateLink", params, http.MethodGet)

10
service/meituan/api.getqualityscorebysid.go
Unescape View File

@ -2,7 +2,7 @@ package meituan
import ( import (
"encoding/json" "encoding/json"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"go.dtapp.net/library/utils/gotime" "go.dtapp.net/library/utils/gotime"
"net/http" "net/http"
) )
@ -24,19 +24,19 @@ type ApiGetQuaLitYsCoreBySidResponse struct {
type ApiGetQuaLitYsCoreBySidResult struct { type ApiGetQuaLitYsCoreBySidResult struct {
Result ApiGetQuaLitYsCoreBySidResponse // 结果 Result ApiGetQuaLitYsCoreBySidResponse // 结果
Body []byte // 内容 Body []byte // 内容
Http gorequest2.Response // 请求 Http gorequest.Response // 请求
Err error // 错误 Err error // 错误
} }
func NewApiGetQuaLitYsCoreBySidResult(result ApiGetQuaLitYsCoreBySidResponse, body []byte, http gorequest2.Response, err error) *ApiGetQuaLitYsCoreBySidResult { func NewApiGetQuaLitYsCoreBySidResult(result ApiGetQuaLitYsCoreBySidResponse, body []byte, http gorequest.Response, err error) *ApiGetQuaLitYsCoreBySidResult {
return &ApiGetQuaLitYsCoreBySidResult{Result: result, Body: body, Http: http, Err: err} return &ApiGetQuaLitYsCoreBySidResult{Result: result, Body: body, Http: http, Err: err}
} }
// ApiGetQuaLitYsCoreBySid 优选sid质量分&复购率查询 // ApiGetQuaLitYsCoreBySid 优选sid质量分&复购率查询
// https://union.meituan.com/v2/apiDetail?id=28 // https://union.meituan.com/v2/apiDetail?id=28
func (app *App) ApiGetQuaLitYsCoreBySid(notMustParams ...gorequest2.Params) *ApiGetQuaLitYsCoreBySidResult { func (app *App) ApiGetQuaLitYsCoreBySid(notMustParams ...gorequest.Params) *ApiGetQuaLitYsCoreBySidResult {
// 参数 // 参数
params := gorequest2.NewParamsWith(notMustParams...) params := gorequest.NewParamsWith(notMustParams...)
// 请求时刻10位时间戳(秒级)，有效期60s // 请求时刻10位时间戳(秒级)，有效期60s
params["ts"] = gotime.Current().Timestamp() params["ts"] = gotime.Current().Timestamp()
params["appkey"] = app.appKey params["appkey"] = app.appKey

10
service/meituan/api.mini_code.go
Unescape View File

@ -2,7 +2,7 @@ package meituan
import ( import (
"encoding/json" "encoding/json"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
) )
@ -15,11 +15,11 @@ type ApiMiniCodeResponse struct {
type ApiMiniCodeResult struct { type ApiMiniCodeResult struct {
Result ApiMiniCodeResponse // 结果 Result ApiMiniCodeResponse // 结果
Body []byte // 内容 Body []byte // 内容
Http gorequest2.Response // 请求 Http gorequest.Response // 请求
Err error // 错误 Err error // 错误
} }
func NewApiMiniCodeResult(result ApiMiniCodeResponse, body []byte, http gorequest2.Response, err error) *ApiMiniCodeResult { func NewApiMiniCodeResult(result ApiMiniCodeResponse, body []byte, http gorequest.Response, err error) *ApiMiniCodeResult {
return &ApiMiniCodeResult{Result: result, Body: body, Http: http, Err: err} return &ApiMiniCodeResult{Result: result, Body: body, Http: http, Err: err}
} }
@ -27,12 +27,12 @@ func NewApiMiniCodeResult(result ApiMiniCodeResponse, body []byte, http goreques
// https://union.meituan.com/v2/apiDetail?id=26 // https://union.meituan.com/v2/apiDetail?id=26
func (app *App) ApiMiniCode(actId int64, sid string) *ApiMiniCodeResult { func (app *App) ApiMiniCode(actId int64, sid string) *ApiMiniCodeResult {
// 参数 // 参数
param := gorequest2.NewParams() param := gorequest.NewParams()
param.Set("appkey", app.appKey) param.Set("appkey", app.appKey)
param.Set("sid", sid) param.Set("sid", sid)
param.Set("actId", actId) param.Set("actId", actId)
// 转换 // 转换
params := gorequest2.NewParamsWith(param) params := gorequest.NewParamsWith(param)
params["sign"] = app.getSign(app.secret, params) params["sign"] = app.getSign(app.secret, params)
// 请求 // 请求
request, err := app.request("https://openapi.meituan.com/api/miniCode", params, http.MethodGet) request, err := app.request("https://openapi.meituan.com/api/miniCode", params, http.MethodGet)

16
service/meituan/api.order.go
Unescape View File

@ -2,7 +2,7 @@ package meituan
import ( import (
"encoding/json" "encoding/json"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
) )
@ -35,21 +35,21 @@ type ApiOrderResponse struct {
} }
type ApiOrderResult struct { type ApiOrderResult struct {
Result ApiOrderResponse // 结果 Result ApiOrderResponse // 结果
Body []byte // 内容 Body []byte // 内容
Http gorequest2.Response // 请求 Http gorequest.Response // 请求
Err error // 错误 Err error // 错误
} }
func NewApiOrderResult(result ApiOrderResponse, body []byte, http gorequest2.Response, err error) *ApiOrderResult { func NewApiOrderResult(result ApiOrderResponse, body []byte, http gorequest.Response, err error) *ApiOrderResult {
return &ApiOrderResult{Result: result, Body: body, Http: http, Err: err} return &ApiOrderResult{Result: result, Body: body, Http: http, Err: err}
} }
// ApiOrder 单订单查询接口（新版） // ApiOrder 单订单查询接口（新版）
// https://union.meituan.com/v2/apiDetail?id=24 // https://union.meituan.com/v2/apiDetail?id=24
func (app *App) ApiOrder(notMustParams ...gorequest2.Params) *ApiOrderResult { func (app *App) ApiOrder(notMustParams ...gorequest.Params) *ApiOrderResult {
// 参数 // 参数
params := gorequest2.NewParamsWith(notMustParams...) params := gorequest.NewParamsWith(notMustParams...)
// 请求时刻10位时间戳(秒级)，有效期60s // 请求时刻10位时间戳(秒级)，有效期60s
params["appkey"] = app.appKey params["appkey"] = app.appKey
params["sign"] = app.getSign(app.secret, params) params["sign"] = app.getSign(app.secret, params)

10
service/meituan/api.order_list.go
Unescape View File

@ -2,7 +2,7 @@ package meituan
import ( import (
"encoding/json" "encoding/json"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"go.dtapp.net/library/utils/gotime" "go.dtapp.net/library/utils/gotime"
"net/http" "net/http"
) )
@ -36,19 +36,19 @@ type ApiOrderListResponse struct {
type ApiOrderListResult struct { type ApiOrderListResult struct {
Result ApiOrderListResponse // 结果 Result ApiOrderListResponse // 结果
Body []byte // 内容 Body []byte // 内容
Http gorequest2.Response // 请求 Http gorequest.Response // 请求
Err error // 错误 Err error // 错误
} }
func NewApiOrderListResult(result ApiOrderListResponse, body []byte, http gorequest2.Response, err error) *ApiOrderListResult { func NewApiOrderListResult(result ApiOrderListResponse, body []byte, http gorequest.Response, err error) *ApiOrderListResult {
return &ApiOrderListResult{Result: result, Body: body, Http: http, Err: err} return &ApiOrderListResult{Result: result, Body: body, Http: http, Err: err}
} }
// ApiOrderList 订单列表查询接口（新版） // ApiOrderList 订单列表查询接口（新版）
// https://union.meituan.com/v2/apiDetail?id=23 // https://union.meituan.com/v2/apiDetail?id=23
func (app *App) ApiOrderList(notMustParams ...gorequest2.Params) *ApiOrderListResult { func (app *App) ApiOrderList(notMustParams ...gorequest.Params) *ApiOrderListResult {
// 参数 // 参数
params := gorequest2.NewParamsWith(notMustParams...) params := gorequest.NewParamsWith(notMustParams...)
// 请求时刻10位时间戳(秒级)，有效期60s // 请求时刻10位时间戳(秒级)，有效期60s
params["ts"] = gotime.Current().Timestamp() params["ts"] = gotime.Current().Timestamp()
params["appkey"] = app.appKey params["appkey"] = app.appKey

16
service/meituan/pgsql.go
Unescape View File

@ -2,18 +2,18 @@ package meituan
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Record(golog2.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部
@ -21,6 +21,6 @@ func (app *App) postgresqlLog(request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: request.ResponseBody, //【返回】内容 ResponseBody: request.ResponseBody, //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

16
service/meituan/poi.area.go
Unescape View File

@ -2,7 +2,7 @@ package meituan
import ( import (
"encoding/json" "encoding/json"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
) )
@ -19,13 +19,13 @@ type PoiAreaResponse struct {
} }
type PoiAreaResult struct { type PoiAreaResult struct {
Result PoiAreaResponse // 结果 Result PoiAreaResponse // 结果
Body []byte // 内容 Body []byte // 内容
Http gorequest2.Response // 请求 Http gorequest.Response // 请求
Err error // 错误 Err error // 错误
} }
func NewPoiAreaResult(result PoiAreaResponse, body []byte, http gorequest2.Response, err error) *PoiAreaResult { func NewPoiAreaResult(result PoiAreaResponse, body []byte, http gorequest.Response, err error) *PoiAreaResult {
return &PoiAreaResult{Result: result, Body: body, Http: http, Err: err} return &PoiAreaResult{Result: result, Body: body, Http: http, Err: err}
} }
@ -33,9 +33,9 @@ func NewPoiAreaResult(result PoiAreaResponse, body []byte, http gorequest2.Respo
// https://openapi.meituan.com/#api-0.%E5%9F%BA%E7%A1%80%E6%95%B0%E6%8D%AE-GetHttpsOpenapiMeituanComPoiAreaCityid1 // https://openapi.meituan.com/#api-0.%E5%9F%BA%E7%A1%80%E6%95%B0%E6%8D%AE-GetHttpsOpenapiMeituanComPoiAreaCityid1
func (app *App) PoiArea(cityID int) *PoiAreaResult { func (app *App) PoiArea(cityID int) *PoiAreaResult {
// 参数 // 参数
param := gorequest2.NewParams() param := gorequest.NewParams()
param.Set("cityid", cityID) param.Set("cityid", cityID)
params := gorequest2.NewParamsWith(param) params := gorequest.NewParamsWith(param)
// 请求 // 请求
request, err := app.request("https://openapi.meituan.com/poi/area", params, http.MethodGet) request, err := app.request("https://openapi.meituan.com/poi/area", params, http.MethodGet)
// 定义 // 定义

10
service/meituan/poi.category.go
Unescape View File

@ -2,7 +2,7 @@ package meituan
import ( import (
"encoding/json" "encoding/json"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
) )
@ -21,11 +21,11 @@ type PoiCategoryResponse struct {
type PoiCategoryResult struct { type PoiCategoryResult struct {
Result PoiCategoryResponse // 结果 Result PoiCategoryResponse // 结果
Body []byte // 内容 Body []byte // 内容
Http gorequest2.Response // 请求 Http gorequest.Response // 请求
Err error // 错误 Err error // 错误
} }
func NewPoiCategoryResult(result PoiCategoryResponse, body []byte, http gorequest2.Response, err error) *PoiCategoryResult { func NewPoiCategoryResult(result PoiCategoryResponse, body []byte, http gorequest.Response, err error) *PoiCategoryResult {
return &PoiCategoryResult{Result: result, Body: body, Http: http, Err: err} return &PoiCategoryResult{Result: result, Body: body, Http: http, Err: err}
} }
@ -33,9 +33,9 @@ func NewPoiCategoryResult(result PoiCategoryResponse, body []byte, http goreques
// https://openapi.meituan.com/#api-0.%E5%9F%BA%E7%A1%80%E6%95%B0%E6%8D%AE-GetHttpsOpenapiMeituanComPoiDistrictCityid1 // https://openapi.meituan.com/#api-0.%E5%9F%BA%E7%A1%80%E6%95%B0%E6%8D%AE-GetHttpsOpenapiMeituanComPoiDistrictCityid1
func (app *App) PoiCategory(cityID int) *PoiCategoryResult { func (app *App) PoiCategory(cityID int) *PoiCategoryResult {
// 参数 // 参数
param := gorequest2.NewParams() param := gorequest.NewParams()
param.Set("cityid", cityID) param.Set("cityid", cityID)
params := gorequest2.NewParamsWith(param) params := gorequest.NewParamsWith(param)
// 请求 // 请求
request, err := app.request("https://openapi.meituan.com/poi/category", params, http.MethodGet) request, err := app.request("https://openapi.meituan.com/poi/category", params, http.MethodGet)
// 定义 // 定义

10
service/meituan/poi.district.go
Unescape View File

@ -2,7 +2,7 @@ package meituan
import ( import (
"encoding/json" "encoding/json"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
) )
@ -17,11 +17,11 @@ type PoiDistrictResponse struct {
type PoiDistrictResult struct { type PoiDistrictResult struct {
Result PoiDistrictResponse // 结果 Result PoiDistrictResponse // 结果
Body []byte // 内容 Body []byte // 内容
Http gorequest2.Response // 请求 Http gorequest.Response // 请求
Err error // 错误 Err error // 错误
} }
func NewPoiDistrictResult(result PoiDistrictResponse, body []byte, http gorequest2.Response, err error) *PoiDistrictResult { func NewPoiDistrictResult(result PoiDistrictResponse, body []byte, http gorequest.Response, err error) *PoiDistrictResult {
return &PoiDistrictResult{Result: result, Body: body, Http: http, Err: err} return &PoiDistrictResult{Result: result, Body: body, Http: http, Err: err}
} }
@ -29,9 +29,9 @@ func NewPoiDistrictResult(result PoiDistrictResponse, body []byte, http goreques
// https://openapi.meituan.com/#api-0.%E5%9F%BA%E7%A1%80%E6%95%B0%E6%8D%AE-GetHttpsOpenapiMeituanComPoiDistrictCityid1 // https://openapi.meituan.com/#api-0.%E5%9F%BA%E7%A1%80%E6%95%B0%E6%8D%AE-GetHttpsOpenapiMeituanComPoiDistrictCityid1
func (app *App) PoiDistrict(cityID int) *PoiDistrictResult { func (app *App) PoiDistrict(cityID int) *PoiDistrictResult {
// 参数 // 参数
param := gorequest2.NewParams() param := gorequest.NewParams()
param.Set("cityid", cityID) param.Set("cityid", cityID)
params := gorequest2.NewParamsWith(param) params := gorequest.NewParamsWith(param)
// 请求 // 请求
request, err := app.request("https://openapi.meituan.com/poi/district", params, http.MethodGet) request, err := app.request("https://openapi.meituan.com/poi/district", params, http.MethodGet)
// 定义 // 定义

5
service/pconline/app.go
Unescape View File

@ -1,8 +1,7 @@
package pconline package pconline
import ( import (
"go.dtapp.net/library/golog" "go.dtapp.net/library/utils/golog"
golog2 "go.dtapp.net/library/utils/golog"
"go.dtapp.net/library/utils/gomongo" "go.dtapp.net/library/utils/gomongo"
"go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/gorm" "gorm.io/gorm"
@ -12,7 +11,7 @@ type App struct {
mongo *gomongo.Client // 日志数据库 mongo *gomongo.Client // 日志数据库
pgsql *gorm.DB // pgsql数据库 pgsql *gorm.DB // pgsql数据库
client *gorequest.App // 请求客户端 client *gorequest.App // 请求客户端
log *golog2.Api // 日志服务 log *golog.Api // 日志服务
logTableName string // 日志表名 logTableName string // 日志表名
logStatus bool // 日志状态 logStatus bool // 日志状态
} }

12
service/pconline/mongo.go
Unescape View File

@ -2,7 +2,7 @@ package pconline
import ( import (
"go.dtapp.net/library/utils/gomongo" "go.dtapp.net/library/utils/gomongo"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
) )
@ -13,8 +13,8 @@ type mongoZap struct {
RequestUrl string `json:"request_url" bson:"request_url"` //【请求】链接 RequestUrl string `json:"request_url" bson:"request_url"` //【请求】链接
RequestApi string `json:"request_api" bson:"request_api"` //【请求】接口 RequestApi string `json:"request_api" bson:"request_api"` //【请求】接口
RequestMethod string `json:"request_method" bson:"request_method"` //【请求】方式 RequestMethod string `json:"request_method" bson:"request_method"` //【请求】方式
RequestParams gorequest2.Params `json:"request_params" bson:"request_params"` //【请求】参数 RequestParams gorequest.Params `json:"request_params" bson:"request_params"` //【请求】参数
RequestHeader gorequest2.Headers `json:"request_header" bson:"request_header"` //【请求】头部 RequestHeader gorequest.Headers `json:"request_header" bson:"request_header"` //【请求】头部
ResponseHeader http.Header `json:"response_header" bson:"response_header"` //【返回】头部 ResponseHeader http.Header `json:"response_header" bson:"response_header"` //【返回】头部
ResponseStatusCode int `json:"response_status_code" bson:"response_status_code"` //【返回】状态码 ResponseStatusCode int `json:"response_status_code" bson:"response_status_code"` //【返回】状态码
ResponseBody map[string]interface{} `json:"response_body" bson:"response_body"` //【返回】内容 ResponseBody map[string]interface{} `json:"response_body" bson:"response_body"` //【返回】内容
@ -30,12 +30,12 @@ func (m *mongoZap) TableName() string {
return "pconline" return "pconline"
} }
func (app *App) mongoLog(request gorequest2.Response) { func (app *App) mongoLog(request gorequest.Response) {
_, _ = app.mongo.Model(&mongoZap{}).InsertOne(mongoZap{ _, _ = app.mongo.Model(&mongoZap{}).InsertOne(mongoZap{
RequestTime: gomongo.BsonTime(request.RequestTime), //【请求】时间 RequestTime: gomongo.BsonTime(request.RequestTime), //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: request.RequestParams, //【请求】参数 RequestParams: request.RequestParams, //【请求】参数
RequestHeader: request.RequestHeader, //【请求】头部 RequestHeader: request.RequestHeader, //【请求】头部

16
service/pconline/pgsql.go
Unescape View File

@ -2,18 +2,18 @@ package pconline
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Api.Record(golog2.ApiPostgresqlLog{ app.log.Api.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部
@ -21,6 +21,6 @@ func (app *App) postgresqlLog(request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: request.ResponseBody, //【返回】内容 ResponseBody: request.ResponseBody, //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

14
service/pinduoduo/pgsql.go
Unescape View File

@ -2,17 +2,17 @@ package pinduoduo
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(api string, request gorequest2.Response) { func (app *App) postgresqlLog(api string, request gorequest.Response) {
app.log.Record(golog2.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: api, //【请求】接口 RequestApi: api, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
@ -21,6 +21,6 @@ func (app *App) postgresqlLog(api string, request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: request.ResponseBody, //【返回】内容 ResponseBody: request.ResponseBody, //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

16
service/pintoto/pgsql.go
Unescape View File

@ -2,18 +2,18 @@ package pintoto
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Record(golog2.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部
@ -21,6 +21,6 @@ func (app *App) postgresqlLog(request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: request.ResponseBody, //【返回】内容 ResponseBody: request.ResponseBody, //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

38
service/sendcloud/mongo.go
Unescape View File

@ -1,25 +1,25 @@
package sendcloud package sendcloud
import ( import (
gomongo2 "go.dtapp.net/library/utils/gomongo" "go.dtapp.net/library/utils/gomongo"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
) )
// 日志 // 日志
type mongoZap struct { type mongoZap struct {
RequestTime gomongo2.BsonTime `json:"request_time" bson:"request_time"` //【请求】时间 RequestTime gomongo.BsonTime `json:"request_time" bson:"request_time"` //【请求】时间
RequestUri string `json:"request_uri" bson:"request_uri"` //【请求】链接 RequestUri string `json:"request_uri" bson:"request_uri"` //【请求】链接
RequestUrl string `json:"request_url" bson:"request_url"` //【请求】链接 RequestUrl string `json:"request_url" bson:"request_url"` //【请求】链接
RequestApi string `json:"request_api" bson:"request_api"` //【请求】接口 RequestApi string `json:"request_api" bson:"request_api"` //【请求】接口
RequestMethod string `json:"request_method" bson:"request_method"` //【请求】方式 RequestMethod string `json:"request_method" bson:"request_method"` //【请求】方式
RequestParams gorequest2.Params `json:"request_params" bson:"request_params"` //【请求】参数 RequestParams gorequest.Params `json:"request_params" bson:"request_params"` //【请求】参数
RequestHeader gorequest2.Headers `json:"request_header" bson:"request_header"` //【请求】头部 RequestHeader gorequest.Headers `json:"request_header" bson:"request_header"` //【请求】头部
ResponseHeader http.Header `json:"response_header" bson:"response_header"` //【返回】头部 ResponseHeader http.Header `json:"response_header" bson:"response_header"` //【返回】头部
ResponseStatusCode int `json:"response_status_code" bson:"response_status_code"` //【返回】状态码 ResponseStatusCode int `json:"response_status_code" bson:"response_status_code"` //【返回】状态码
ResponseBody map[string]interface{} `json:"response_body" bson:"response_body"` //【返回】内容 ResponseBody map[string]interface{} `json:"response_body" bson:"response_body"` //【返回】内容
ResponseContentLength int64 `json:"response_content_length" bson:"response_content_length"` //【返回】大小 ResponseContentLength int64 `json:"response_content_length" bson:"response_content_length"` //【返回】大小
ResponseTime gomongo2.BsonTime `json:"response_time" bson:"response_time"` //【返回】时间 ResponseTime gomongo.BsonTime `json:"response_time" bson:"response_time"` //【返回】时间
} }
func (m *mongoZap) Database() string { func (m *mongoZap) Database() string {
@ -30,19 +30,19 @@ func (m *mongoZap) TableName() string {
return "sendcloud" return "sendcloud"
} }
func (app *App) mongoLog(request gorequest2.Response) { func (app *App) mongoLog(request gorequest.Response) {
_, _ = app.mongo.Model(&mongoZap{}).InsertOne(mongoZap{ _, _ = app.mongo.Model(&mongoZap{}).InsertOne(mongoZap{
RequestTime: gomongo2.BsonTime(request.RequestTime), //【请求】时间 RequestTime: gomongo.BsonTime(request.RequestTime), //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: request.RequestParams, //【请求】参数 RequestParams: request.RequestParams, //【请求】参数
RequestHeader: request.RequestHeader, //【请求】头部 RequestHeader: request.RequestHeader, //【请求】头部
ResponseHeader: request.ResponseHeader, //【返回】头部 ResponseHeader: request.ResponseHeader, //【返回】头部
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: gomongo2.JsonDecodeNoError(request.ResponseBody), //【返回】内容 ResponseBody: gomongo.JsonDecodeNoError(request.ResponseBody), //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: gomongo2.BsonTime(request.ResponseTime), //【返回】时间 ResponseTime: gomongo.BsonTime(request.ResponseTime), //【返回】时间
}) })
} }

8
service/sendcloud/pgsql.go
Unescape View File

@ -3,17 +3,17 @@ package sendcloud
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
"go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Record(golog.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: request.RequestTime, //【请求】时间 RequestTime: request.RequestTime, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部

14
service/taobao/pgsql.go
Unescape View File

@ -2,17 +2,17 @@ package taobao
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(api string, request gorequest2.Response) { func (app *App) postgresqlLog(api string, request gorequest.Response) {
app.log.Record(golog2.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: api, //【请求】接口 RequestApi: api, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
@ -21,6 +21,6 @@ func (app *App) postgresqlLog(api string, request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: request.ResponseBody, //【返回】内容 ResponseBody: request.ResponseBody, //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

16
service/wechatminiprogram/pgsql.go
Unescape View File

@ -2,25 +2,25 @@ package wechatminiprogram
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
body := golog2.ApiPostgresqlLog{} body := golog.ApiPostgresqlLog{}
body.RequestTime = golog2.TimeString{Time: request.RequestTime} //【请求】时间 body.RequestTime = golog.TimeString{Time: request.RequestTime} //【请求】时间
body.RequestUri = request.RequestUri //【请求】链接 body.RequestUri = request.RequestUri //【请求】链接
body.RequestUrl = gorequest2.UriParse(request.RequestUri).Url //【请求】链接 body.RequestUrl = gorequest.UriParse(request.RequestUri).Url //【请求】链接
body.RequestApi = gorequest2.UriParse(request.RequestUri).Path //【请求】接口 body.RequestApi = gorequest.UriParse(request.RequestUri).Path //【请求】接口
body.RequestMethod = request.RequestMethod //【请求】方式 body.RequestMethod = request.RequestMethod //【请求】方式
body.RequestParams = datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)) //【请求】参数 body.RequestParams = datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)) //【请求】参数
body.RequestHeader = datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)) //【请求】头部 body.RequestHeader = datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)) //【请求】头部
body.ResponseHeader = datatypes.JSON(gojson.JsonEncodeNoError(request.ResponseHeader)) //【返回】头部 body.ResponseHeader = datatypes.JSON(gojson.JsonEncodeNoError(request.ResponseHeader)) //【返回】头部
body.ResponseStatusCode = request.ResponseStatusCode //【返回】状态码 body.ResponseStatusCode = request.ResponseStatusCode //【返回】状态码
body.ResponseContentLength = request.ResponseContentLength //【返回】大小 body.ResponseContentLength = request.ResponseContentLength //【返回】大小
body.ResponseTime = golog2.TimeString{Time: request.ResponseTime} //【返回】时间 body.ResponseTime = golog.TimeString{Time: request.ResponseTime} //【返回】时间
if request.ResponseHeader.Get("Content-Type") == "image/jpeg" || request.ResponseHeader.Get("Content-Type") == "image/png" { if request.ResponseHeader.Get("Content-Type") == "image/jpeg" || request.ResponseHeader.Get("Content-Type") == "image/png" {
} else { } else {
body.ResponseBody = request.ResponseBody //【返回】内容 body.ResponseBody = request.ResponseBody //【返回】内容

16
service/wechatoffice/pgsql.go
Unescape View File

@ -2,18 +2,18 @@ package wechatoffice
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Record(golog2.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部
@ -21,6 +21,6 @@ func (app *App) postgresqlLog(request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: request.ResponseBody, //【返回】内容 ResponseBody: request.ResponseBody, //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

16
service/wechatopen/pgsql.go
Unescape View File

@ -2,18 +2,18 @@ package wechatopen
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Record(golog2.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部
@ -21,6 +21,6 @@ func (app *App) postgresqlLog(request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: request.ResponseBody, //【返回】内容 ResponseBody: request.ResponseBody, //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

8
service/wechatopen/wxa.business.getuserphonenumber.go
Unescape View File

@ -3,7 +3,7 @@ package wechatopen
import ( import (
"encoding/json" "encoding/json"
"fmt" "fmt"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
) )
@ -24,11 +24,11 @@ type WxaBusinessGetUserPhoneNumberResponse struct {
type WxaBusinessGetUserPhoneNumberResult struct { type WxaBusinessGetUserPhoneNumberResult struct {
Result WxaBusinessGetUserPhoneNumberResponse // 结果 Result WxaBusinessGetUserPhoneNumberResponse // 结果
Body []byte // 内容 Body []byte // 内容
Http gorequest2.Response // 请求 Http gorequest.Response // 请求
Err error // 错误 Err error // 错误
} }
func NewWxaBusinessGetUserPhoneNumberResult(result WxaBusinessGetUserPhoneNumberResponse, body []byte, http gorequest2.Response, err error) *WxaBusinessGetUserPhoneNumberResult { func NewWxaBusinessGetUserPhoneNumberResult(result WxaBusinessGetUserPhoneNumberResponse, body []byte, http gorequest.Response, err error) *WxaBusinessGetUserPhoneNumberResult {
return &WxaBusinessGetUserPhoneNumberResult{Result: result, Body: body, Http: http, Err: err} return &WxaBusinessGetUserPhoneNumberResult{Result: result, Body: body, Http: http, Err: err}
} }
@ -36,7 +36,7 @@ func NewWxaBusinessGetUserPhoneNumberResult(result WxaBusinessGetUserPhoneNumber
// https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/phonenumber/phonenumber.getPhoneNumber.html // https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/phonenumber/phonenumber.getPhoneNumber.html
func (app *App) WxaBusinessGetUserPhoneNumber(code string) *WxaBusinessGetUserPhoneNumberResult { func (app *App) WxaBusinessGetUserPhoneNumber(code string) *WxaBusinessGetUserPhoneNumberResult {
// 参数 // 参数
params := gorequest2.NewParams() params := gorequest.NewParams()
params.Set("code", code) params.Set("code", code)
// 请求 // 请求
request, err := app.request(fmt.Sprintf("https://api.weixin.qq.com/wxa/business/getuserphonenumber?access_token=%s", app.GetAuthorizerAccessToken()), params, http.MethodPost) request, err := app.request(fmt.Sprintf("https://api.weixin.qq.com/wxa/business/getuserphonenumber?access_token=%s", app.GetAuthorizerAccessToken()), params, http.MethodPost)

16
service/wechatopen/wxa.commit.go
Unescape View File

@ -3,7 +3,7 @@ package wechatopen
import ( import (
"encoding/json" "encoding/json"
"fmt" "fmt"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
) )
@ -13,21 +13,21 @@ type WxaCommitResponse struct {
} }
type WxaCommitResult struct { type WxaCommitResult struct {
Result WxaCommitResponse // 结果 Result WxaCommitResponse // 结果
Body []byte // 内容 Body []byte // 内容
Http gorequest2.Response // 请求 Http gorequest.Response // 请求
Err error // 错误 Err error // 错误
} }
func NewWxaCommitResult(result WxaCommitResponse, body []byte, http gorequest2.Response, err error) *WxaCommitResult { func NewWxaCommitResult(result WxaCommitResponse, body []byte, http gorequest.Response, err error) *WxaCommitResult {
return &WxaCommitResult{Result: result, Body: body, Http: http, Err: err} return &WxaCommitResult{Result: result, Body: body, Http: http, Err: err}
} }
// WxaCommit 上传小程序代码并生成体验版 // WxaCommit 上传小程序代码并生成体验版
// https://developers.weixin.qq.com/doc/oplatform/Third-party_Platforms/2.0/api/code/commit.html // https://developers.weixin.qq.com/doc/oplatform/Third-party_Platforms/2.0/api/code/commit.html
func (app *App) WxaCommit(notMustParams ...gorequest2.Params) *WxaCommitResult { func (app *App) WxaCommit(notMustParams ...gorequest.Params) *WxaCommitResult {
// 参数 // 参数
params := gorequest2.NewParamsWith(notMustParams...) params := gorequest.NewParamsWith(notMustParams...)
// 请求 // 请求
request, err := app.request(fmt.Sprintf("https://api.weixin.qq.com/wxa/commit?access_token=%s", app.GetAuthorizerAccessToken()), params, http.MethodPost) request, err := app.request(fmt.Sprintf("https://api.weixin.qq.com/wxa/commit?access_token=%s", app.GetAuthorizerAccessToken()), params, http.MethodPost)
// 定义 // 定义

12
service/wechatpayapiv2/mongodb.go
Unescape View File

@ -2,7 +2,7 @@ package wechatpayapiv2
import ( import (
"go.dtapp.net/library/utils/gomongo" "go.dtapp.net/library/utils/gomongo"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
) )
@ -13,8 +13,8 @@ type mongoZap struct {
RequestUrl string `json:"request_url" bson:"request_url"` //【请求】链接 RequestUrl string `json:"request_url" bson:"request_url"` //【请求】链接
RequestApi string `json:"request_api" bson:"request_api"` //【请求】接口 RequestApi string `json:"request_api" bson:"request_api"` //【请求】接口
RequestMethod string `json:"request_method" bson:"request_method"` //【请求】方式 RequestMethod string `json:"request_method" bson:"request_method"` //【请求】方式
RequestParams gorequest2.Params `json:"request_params" bson:"request_params"` //【请求】参数 RequestParams gorequest.Params `json:"request_params" bson:"request_params"` //【请求】参数
RequestHeader gorequest2.Headers `json:"request_header" bson:"request_header"` //【请求】头部 RequestHeader gorequest.Headers `json:"request_header" bson:"request_header"` //【请求】头部
ResponseHeader http.Header `json:"response_header" bson:"response_header"` //【返回】头部 ResponseHeader http.Header `json:"response_header" bson:"response_header"` //【返回】头部
ResponseStatusCode int `json:"response_status_code" bson:"response_status_code"` //【返回】状态码 ResponseStatusCode int `json:"response_status_code" bson:"response_status_code"` //【返回】状态码
ResponseBody map[string]interface{} `json:"response_body" bson:"response_body"` //【返回】内容 ResponseBody map[string]interface{} `json:"response_body" bson:"response_body"` //【返回】内容
@ -31,12 +31,12 @@ func (m *mongoZap) TableName() string {
return "wechatpayapiv2" return "wechatpayapiv2"
} }
func (app *App) mongoLog(request gorequest2.Response) { func (app *App) mongoLog(request gorequest.Response) {
_, _ = app.mongo.Model(&mongoZap{}).InsertOne(mongoZap{ _, _ = app.mongo.Model(&mongoZap{}).InsertOne(mongoZap{
RequestTime: gomongo.BsonTime(request.RequestTime), //【请求】时间 RequestTime: gomongo.BsonTime(request.RequestTime), //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: request.RequestParams, //【请求】参数 RequestParams: request.RequestParams, //【请求】参数
RequestHeader: request.RequestHeader, //【请求】头部 RequestHeader: request.RequestHeader, //【请求】头部

16
service/wechatpayapiv2/pgsql.go
Unescape View File

@ -2,19 +2,19 @@ package wechatpayapiv2
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
"go.dtapp.net/library/utils/gomongo" "go.dtapp.net/library/utils/gomongo"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Record(golog2.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部
@ -22,6 +22,6 @@ func (app *App) postgresqlLog(request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: datatypes.JSON(gojson.JsonEncodeNoError(gomongo.XmlDecodeNoError(request.ResponseBody))), //【返回】内容 ResponseBody: datatypes.JSON(gojson.JsonEncodeNoError(gomongo.XmlDecodeNoError(request.ResponseBody))), //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

12
service/wechatpayapiv3/mongo.go
Unescape View File

@ -2,7 +2,7 @@ package wechatpayapiv3
import ( import (
"go.dtapp.net/library/utils/gomongo" "go.dtapp.net/library/utils/gomongo"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
) )
@ -13,8 +13,8 @@ type mongoZap struct {
RequestUrl string `json:"request_url" bson:"request_url"` //【请求】链接 RequestUrl string `json:"request_url" bson:"request_url"` //【请求】链接
RequestApi string `json:"request_api" bson:"request_api"` //【请求】接口 RequestApi string `json:"request_api" bson:"request_api"` //【请求】接口
RequestMethod string `json:"request_method" bson:"request_method"` //【请求】方式 RequestMethod string `json:"request_method" bson:"request_method"` //【请求】方式
RequestParams gorequest2.Params `json:"request_params" bson:"request_params"` //【请求】参数 RequestParams gorequest.Params `json:"request_params" bson:"request_params"` //【请求】参数
RequestHeader gorequest2.Headers `json:"request_header" bson:"request_header"` //【请求】头部 RequestHeader gorequest.Headers `json:"request_header" bson:"request_header"` //【请求】头部
ResponseHeader http.Header `json:"response_header" bson:"response_header"` //【返回】头部 ResponseHeader http.Header `json:"response_header" bson:"response_header"` //【返回】头部
ResponseStatusCode int `json:"response_status_code" bson:"response_status_code"` //【返回】状态码 ResponseStatusCode int `json:"response_status_code" bson:"response_status_code"` //【返回】状态码
ResponseBody map[string]interface{} `json:"response_body" bson:"response_body"` //【返回】内容 ResponseBody map[string]interface{} `json:"response_body" bson:"response_body"` //【返回】内容
@ -30,12 +30,12 @@ func (m *mongoZap) TableName() string {
return "wechatpayapiv3" return "wechatpayapiv3"
} }
func (app *App) mongoLog(request gorequest2.Response) { func (app *App) mongoLog(request gorequest.Response) {
_, _ = app.mongo.Model(&mongoZap{}).InsertOne(mongoZap{ _, _ = app.mongo.Model(&mongoZap{}).InsertOne(mongoZap{
RequestTime: gomongo.BsonTime(request.RequestTime), //【请求】时间 RequestTime: gomongo.BsonTime(request.RequestTime), //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: request.RequestParams, //【请求】参数 RequestParams: request.RequestParams, //【请求】参数
RequestHeader: request.RequestHeader, //【请求】头部 RequestHeader: request.RequestHeader, //【请求】头部

16
service/wechatpayapiv3/pgsql.go
Unescape View File

@ -2,18 +2,18 @@ package wechatpayapiv3
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Record(golog2.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部
@ -21,6 +21,6 @@ func (app *App) postgresqlLog(request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: request.ResponseBody, //【返回】内容 ResponseBody: request.ResponseBody, //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

8
service/wechatpayopen/pay.partner.transactions.id.go
Unescape View File

@ -3,7 +3,7 @@ package wechatpayopen
import ( import (
"encoding/json" "encoding/json"
"fmt" "fmt"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
) )
@ -54,11 +54,11 @@ type PayPartnerTransactionsIdResponse struct {
type PayPartnerTransactionsIdResult struct { type PayPartnerTransactionsIdResult struct {
Result PayPartnerTransactionsIdResponse // 结果 Result PayPartnerTransactionsIdResponse // 结果
Body []byte // 内容 Body []byte // 内容
Http gorequest2.Response // 请求 Http gorequest.Response // 请求
Err error // 错误 Err error // 错误
} }
func NewPayPartnerTransactionsIdResult(result PayPartnerTransactionsIdResponse, body []byte, http gorequest2.Response, err error) *PayPartnerTransactionsIdResult { func NewPayPartnerTransactionsIdResult(result PayPartnerTransactionsIdResponse, body []byte, http gorequest.Response, err error) *PayPartnerTransactionsIdResult {
return &PayPartnerTransactionsIdResult{Result: result, Body: body, Http: http, Err: err} return &PayPartnerTransactionsIdResult{Result: result, Body: body, Http: http, Err: err}
} }
@ -66,7 +66,7 @@ func NewPayPartnerTransactionsIdResult(result PayPartnerTransactionsIdResponse,
// https://pay.weixin.qq.com/wiki/doc/apiv3_partner/apis/chapter4_5_2.shtml // https://pay.weixin.qq.com/wiki/doc/apiv3_partner/apis/chapter4_5_2.shtml
func (app *App) PayPartnerTransactionsId(transactionId string) *PayPartnerTransactionsIdResult { func (app *App) PayPartnerTransactionsId(transactionId string) *PayPartnerTransactionsIdResult {
// 参数 // 参数
params := gorequest2.NewParams() params := gorequest.NewParams()
// 请求 // 请求
// 请求 // 请求
request, err := app.request(fmt.Sprintf("https://api.mch.weixin.qq.com/v3/pay/partner/transactions/id/%s?sp_mchid=%s&sub_mchid=%s", transactionId, app.spMchId, app.subMchId), params, http.MethodGet) request, err := app.request(fmt.Sprintf("https://api.mch.weixin.qq.com/v3/pay/partner/transactions/id/%s?sp_mchid=%s&sub_mchid=%s", transactionId, app.spMchId, app.subMchId), params, http.MethodGet)

10
service/wechatpayopen/pay.partner.transactions.jsapi.go
Unescape View File

@ -2,7 +2,7 @@ package wechatpayopen
import ( import (
"encoding/json" "encoding/json"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
) )
@ -13,19 +13,19 @@ type PayPartnerTransactionsJsapiResponse struct {
type PayPartnerTransactionsJsapiResult struct { type PayPartnerTransactionsJsapiResult struct {
Result PayPartnerTransactionsJsapiResponse // 结果 Result PayPartnerTransactionsJsapiResponse // 结果
Body []byte // 内容 Body []byte // 内容
Http gorequest2.Response // 请求 Http gorequest.Response // 请求
Err error // 错误 Err error // 错误
} }
func NewPayPartnerTransactionsJsapiResult(result PayPartnerTransactionsJsapiResponse, body []byte, http gorequest2.Response, err error) *PayPartnerTransactionsJsapiResult { func NewPayPartnerTransactionsJsapiResult(result PayPartnerTransactionsJsapiResponse, body []byte, http gorequest.Response, err error) *PayPartnerTransactionsJsapiResult {
return &PayPartnerTransactionsJsapiResult{Result: result, Body: body, Http: http, Err: err} return &PayPartnerTransactionsJsapiResult{Result: result, Body: body, Http: http, Err: err}
} }
// PayPartnerTransactionsJsapi JSAPI下单 // PayPartnerTransactionsJsapi JSAPI下单
// https://pay.weixin.qq.com/wiki/doc/apiv3_partner/apis/chapter4_5_1.shtml // https://pay.weixin.qq.com/wiki/doc/apiv3_partner/apis/chapter4_5_1.shtml
func (app *App) PayPartnerTransactionsJsapi(notMustParams ...gorequest2.Params) *PayPartnerTransactionsJsapiResult { func (app *App) PayPartnerTransactionsJsapi(notMustParams ...gorequest.Params) *PayPartnerTransactionsJsapiResult {
// 参数 // 参数
params := gorequest2.NewParamsWith(notMustParams...) params := gorequest.NewParamsWith(notMustParams...)
params.Set("sp_appid", app.spAppid) // 服务商应用ID params.Set("sp_appid", app.spAppid) // 服务商应用ID
params.Set("sp_mchid", app.spMchId) // 服务商户号 params.Set("sp_mchid", app.spMchId) // 服务商户号
params.Set("sub_appid", app.subAppid) // 子商户应用ID params.Set("sub_appid", app.subAppid) // 子商户应用ID

12
service/wechatpayopen/pay.partner.transactions.out-trade-no.close.go
Unescape View File

@ -2,17 +2,17 @@ package wechatpayopen
import ( import (
"fmt" "fmt"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
) )
type PayPartnerTransactionsOutTradeNoCloseResult struct { type PayPartnerTransactionsOutTradeNoCloseResult struct {
Body []byte // 内容 Body []byte // 内容
Http gorequest2.Response // 请求 Http gorequest.Response // 请求
Err error // 错误 Err error // 错误
} }
func NewPayPartnerTransactionsOutTradeNoCloseResult(body []byte, http gorequest2.Response, err error) *PayPartnerTransactionsOutTradeNoCloseResult { func NewPayPartnerTransactionsOutTradeNoCloseResult(body []byte, http gorequest.Response, err error) *PayPartnerTransactionsOutTradeNoCloseResult {
return &PayPartnerTransactionsOutTradeNoCloseResult{Body: body, Http: http, Err: err} return &PayPartnerTransactionsOutTradeNoCloseResult{Body: body, Http: http, Err: err}
} }
@ -20,7 +20,7 @@ func NewPayPartnerTransactionsOutTradeNoCloseResult(body []byte, http gorequest2
// https://pay.weixin.qq.com/wiki/doc/apiv3_partner/apis/chapter4_5_3.shtml // https://pay.weixin.qq.com/wiki/doc/apiv3_partner/apis/chapter4_5_3.shtml
func (app *App) PayPartnerTransactionsOutTradeNoClose(outTradeNo string) *PayPartnerTransactionsOutTradeNoCloseResult { func (app *App) PayPartnerTransactionsOutTradeNoClose(outTradeNo string) *PayPartnerTransactionsOutTradeNoCloseResult {
// 参数 // 参数
params := gorequest2.NewParams() params := gorequest.NewParams()
params.Set("sp_mchid", app.spMchId) // 服务商户号 params.Set("sp_mchid", app.spMchId) // 服务商户号
params.Set("sub_mchid", app.subMchId) // 子商户号 params.Set("sub_mchid", app.subMchId) // 子商户号
// 请求 // 请求

8
service/wechatpayopen/pay.partner.transactions.out-trade-no.go
Unescape View File

@ -3,7 +3,7 @@ package wechatpayopen
import ( import (
"encoding/json" "encoding/json"
"fmt" "fmt"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
) )
@ -57,11 +57,11 @@ type PayPartnerTransactionsOutTradeNoResponse struct {
type PayPartnerTransactionsOutTradeNoResult struct { type PayPartnerTransactionsOutTradeNoResult struct {
Result PayPartnerTransactionsOutTradeNoResponse // 结果 Result PayPartnerTransactionsOutTradeNoResponse // 结果
Body []byte // 内容 Body []byte // 内容
Http gorequest2.Response // 请求 Http gorequest.Response // 请求
Err error // 错误 Err error // 错误
} }
func NewPayPartnerTransactionsOutTradeNoResult(result PayPartnerTransactionsOutTradeNoResponse, body []byte, http gorequest2.Response, err error) *PayPartnerTransactionsOutTradeNoResult { func NewPayPartnerTransactionsOutTradeNoResult(result PayPartnerTransactionsOutTradeNoResponse, body []byte, http gorequest.Response, err error) *PayPartnerTransactionsOutTradeNoResult {
return &PayPartnerTransactionsOutTradeNoResult{Result: result, Body: body, Http: http, Err: err} return &PayPartnerTransactionsOutTradeNoResult{Result: result, Body: body, Http: http, Err: err}
} }
@ -69,7 +69,7 @@ func NewPayPartnerTransactionsOutTradeNoResult(result PayPartnerTransactionsOutT
// https://pay.weixin.qq.com/wiki/doc/apiv3_partner/apis/chapter4_5_2.shtml // https://pay.weixin.qq.com/wiki/doc/apiv3_partner/apis/chapter4_5_2.shtml
func (app *App) PayPartnerTransactionsOutTradeNo(outTradeNo string) *PayPartnerTransactionsOutTradeNoResult { func (app *App) PayPartnerTransactionsOutTradeNo(outTradeNo string) *PayPartnerTransactionsOutTradeNoResult {
// 参数 // 参数
params := gorequest2.NewParams() params := gorequest.NewParams()
// 请求 // 请求
request, err := app.request(fmt.Sprintf("https://api.mch.weixin.qq.com/v3/pay/partner/transactions/out-trade-no/%s?sp_mchid=%s&sub_mchid=%s", outTradeNo, app.spMchId, app.subMchId), params, http.MethodGet) request, err := app.request(fmt.Sprintf("https://api.mch.weixin.qq.com/v3/pay/partner/transactions/out-trade-no/%s?sp_mchid=%s&sub_mchid=%s", outTradeNo, app.spMchId, app.subMchId), params, http.MethodGet)
if err != nil { if err != nil {

16
service/wechatpayopen/pgsql.go
Unescape View File

@ -2,18 +2,18 @@ package wechatpayopen
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Record(golog2.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部
@ -21,6 +21,6 @@ func (app *App) postgresqlLog(request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: request.ResponseBody, //【返回】内容 ResponseBody: request.ResponseBody, //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

10
service/wechatpayopen/refund.domestic.refunds.go
Unescape View File

@ -2,7 +2,7 @@ package wechatpayopen
import ( import (
"encoding/json" "encoding/json"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
"time" "time"
) )
@ -52,19 +52,19 @@ type RefundDomesticRefundsResponse struct {
type RefundDomesticRefundsResult struct { type RefundDomesticRefundsResult struct {
Result RefundDomesticRefundsResponse // 结果 Result RefundDomesticRefundsResponse // 结果
Body []byte // 内容 Body []byte // 内容
Http gorequest2.Response // 请求 Http gorequest.Response // 请求
Err error // 错误 Err error // 错误
} }
func NewRefundDomesticRefundsResult(result RefundDomesticRefundsResponse, body []byte, http gorequest2.Response, err error) *RefundDomesticRefundsResult { func NewRefundDomesticRefundsResult(result RefundDomesticRefundsResponse, body []byte, http gorequest.Response, err error) *RefundDomesticRefundsResult {
return &RefundDomesticRefundsResult{Result: result, Body: body, Http: http, Err: err} return &RefundDomesticRefundsResult{Result: result, Body: body, Http: http, Err: err}
} }
// RefundDomesticRefunds 申请退款API // RefundDomesticRefunds 申请退款API
// https://pay.weixin.qq.com/wiki/doc/apiv3_partner/apis/chapter4_5_9.shtml // https://pay.weixin.qq.com/wiki/doc/apiv3_partner/apis/chapter4_5_9.shtml
func (app *App) RefundDomesticRefunds(notMustParams ...gorequest2.Params) *RefundDomesticRefundsResult { func (app *App) RefundDomesticRefunds(notMustParams ...gorequest.Params) *RefundDomesticRefundsResult {
// 参数 // 参数
params := gorequest2.NewParamsWith(notMustParams...) params := gorequest.NewParamsWith(notMustParams...)
params.Set("sub_mchid", app.subMchId) // 子商户号 params.Set("sub_mchid", app.subMchId) // 子商户号
// 请求 // 请求
request, err := app.request("https://api.mch.weixin.qq.com/v3/refund/domestic/refunds", params, http.MethodPost) request, err := app.request("https://api.mch.weixin.qq.com/v3/refund/domestic/refunds", params, http.MethodPost)

8
service/wechatpayopen/refund.domestic.refunds.out_refund_no.go
Unescape View File

@ -2,7 +2,7 @@ package wechatpayopen
import ( import (
"encoding/json" "encoding/json"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"net/http" "net/http"
"time" "time"
) )
@ -52,11 +52,11 @@ type RefundDomesticRefundsOutRefundNoResponse struct {
type RefundDomesticRefundsOutRefundNoResult struct { type RefundDomesticRefundsOutRefundNoResult struct {
Result RefundDomesticRefundsOutRefundNoResponse // 结果 Result RefundDomesticRefundsOutRefundNoResponse // 结果
Body []byte // 内容 Body []byte // 内容
Http gorequest2.Response // 请求 Http gorequest.Response // 请求
Err error // 错误 Err error // 错误
} }
func NewRefundDomesticRefundsOutRefundNoResult(result RefundDomesticRefundsOutRefundNoResponse, body []byte, http gorequest2.Response, err error) *RefundDomesticRefundsOutRefundNoResult { func NewRefundDomesticRefundsOutRefundNoResult(result RefundDomesticRefundsOutRefundNoResponse, body []byte, http gorequest.Response, err error) *RefundDomesticRefundsOutRefundNoResult {
return &RefundDomesticRefundsOutRefundNoResult{Result: result, Body: body, Http: http, Err: err} return &RefundDomesticRefundsOutRefundNoResult{Result: result, Body: body, Http: http, Err: err}
} }
@ -64,7 +64,7 @@ func NewRefundDomesticRefundsOutRefundNoResult(result RefundDomesticRefundsOutRe
// https://pay.weixin.qq.com/wiki/doc/apiv3_partner/apis/chapter4_5_9.shtml // https://pay.weixin.qq.com/wiki/doc/apiv3_partner/apis/chapter4_5_9.shtml
func (app *App) RefundDomesticRefundsOutRefundNo(outRefundNo string) *RefundDomesticRefundsOutRefundNoResult { func (app *App) RefundDomesticRefundsOutRefundNo(outRefundNo string) *RefundDomesticRefundsOutRefundNoResult {
// 参数 // 参数
params := gorequest2.NewParams() params := gorequest.NewParams()
// 请求 // 请求
request, err := app.request("https://api.mch.weixin.qq.com/v3/refund/domestic/refunds/"+outRefundNo+"?sub_mchid="+app.subMchId, params, http.MethodGet) request, err := app.request("https://api.mch.weixin.qq.com/v3/refund/domestic/refunds/"+outRefundNo+"?sub_mchid="+app.subMchId, params, http.MethodGet)
if err != nil { if err != nil {

16
service/wechatqy/pgsql.go
Unescape View File

@ -2,18 +2,18 @@ package wechatqy
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Record(golog2.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部
@ -21,6 +21,6 @@ func (app *App) postgresqlLog(request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: request.ResponseBody, //【返回】内容 ResponseBody: request.ResponseBody, //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

10
service/wechatqy/webhook.send.go
Unescape View File

@ -3,7 +3,7 @@ package wechatqy
import ( import (
"encoding/json" "encoding/json"
"fmt" "fmt"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
) )
type WebhookSendResponse struct { type WebhookSendResponse struct {
@ -17,19 +17,19 @@ type WebhookSendResponse struct {
type WebhookSendResult struct { type WebhookSendResult struct {
Result WebhookSendResponse // 结果 Result WebhookSendResponse // 结果
Body []byte // 内容 Body []byte // 内容
Http gorequest2.Response // 请求 Http gorequest.Response // 请求
Err error // 错误 Err error // 错误
} }
func NewWebhookSendResult(result WebhookSendResponse, body []byte, http gorequest2.Response, err error) *WebhookSendResult { func NewWebhookSendResult(result WebhookSendResponse, body []byte, http gorequest.Response, err error) *WebhookSendResult {
return &WebhookSendResult{Result: result, Body: body, Http: http, Err: err} return &WebhookSendResult{Result: result, Body: body, Http: http, Err: err}
} }
// WebhookSend 发送应用消息 // WebhookSend 发送应用消息
// https://developer.work.weixin.qq.com/document/path/90372 // https://developer.work.weixin.qq.com/document/path/90372
func (app *App) WebhookSend(notMustParams ...gorequest2.Params) *WebhookSendResult { func (app *App) WebhookSend(notMustParams ...gorequest.Params) *WebhookSendResult {
// 参数 // 参数
params := gorequest2.NewParamsWith(notMustParams...) params := gorequest.NewParamsWith(notMustParams...)
// 请求 // 请求
request, err := app.request(fmt.Sprintf("https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=%s&type=%s", app.key, "text"), params) request, err := app.request(fmt.Sprintf("https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=%s&type=%s", app.key, "text"), params)
// 定义 // 定义

16
service/wechatunion/pgsql.go
Unescape View File

@ -2,18 +2,18 @@ package wechatunion
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Record(golog2.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部
@ -21,6 +21,6 @@ func (app *App) postgresqlLog(request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: request.ResponseBody, //【返回】内容 ResponseBody: request.ResponseBody, //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

16
service/weishi/pgsql.go
Unescape View File

@ -2,18 +2,18 @@ package weishi
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (ws *WeiShi) postgresqlLog(request gorequest2.Response) { func (ws *WeiShi) postgresqlLog(request gorequest.Response) {
ws.log.Record(golog2.ApiPostgresqlLog{ ws.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部
@ -21,6 +21,6 @@ func (ws *WeiShi) postgresqlLog(request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: request.ResponseBody, //【返回】内容 ResponseBody: request.ResponseBody, //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

16
service/wikeyun/pgsql.go
Unescape View File

@ -2,18 +2,18 @@ package wikeyun
import ( import (
"go.dtapp.net/library/utils/gojson" "go.dtapp.net/library/utils/gojson"
golog2 "go.dtapp.net/library/utils/golog" "go.dtapp.net/library/utils/golog"
gorequest2 "go.dtapp.net/library/utils/gorequest" "go.dtapp.net/library/utils/gorequest"
"gorm.io/datatypes" "gorm.io/datatypes"
) )
// 记录日志 // 记录日志
func (app *App) postgresqlLog(request gorequest2.Response) { func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Record(golog2.ApiPostgresqlLog{ app.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog2.TimeString{Time: request.RequestTime}, //【请求】时间 RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接 RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest2.UriParse(request.RequestUri).Url, //【请求】链接 RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接
RequestApi: gorequest2.UriParse(request.RequestUri).Path, //【请求】接口 RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口
RequestMethod: request.RequestMethod, //【请求】方式 RequestMethod: request.RequestMethod, //【请求】方式
RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数 RequestParams: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestParams)), //【请求】参数
RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部 RequestHeader: datatypes.JSON(gojson.JsonEncodeNoError(request.RequestHeader)), //【返回】头部
@ -21,6 +21,6 @@ func (app *App) postgresqlLog(request gorequest2.Response) {
ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码
ResponseBody: request.ResponseBody, //【返回】内容 ResponseBody: request.ResponseBody, //【返回】内容
ResponseContentLength: request.ResponseContentLength, //【返回】大小 ResponseContentLength: request.ResponseContentLength, //【返回】大小
ResponseTime: golog2.TimeString{Time: request.ResponseTime}, //【返回】时间 ResponseTime: golog.TimeString{Time: request.ResponseTime}, //【返回】时间
}) })
} }

Write Preview
Loading…
Cancel
Save