- update service/kuaidi100

master
李光春 10 months ago
parent dc3bc54468
commit 4f086f2626

@ -40,7 +40,7 @@ require (
gorm.io/driver/postgres v1.5.2 gorm.io/driver/postgres v1.5.2
gorm.io/gen v0.3.23 gorm.io/gen v0.3.23
gorm.io/gorm v1.25.2 gorm.io/gorm v1.25.2
xorm.io/builder v0.3.12 xorm.io/builder v0.3.13
xorm.io/xorm v1.3.2 xorm.io/xorm v1.3.2
) )

@ -953,7 +953,7 @@ rsc.io/pdf v0.1.1/go.mod h1:n8OzWcQ6Sp37PL01nO98y4iUCRdTGarVfzxY20ICaU4=
sigs.k8s.io/yaml v1.1.0/go.mod h1:UJmg0vDUVViEyp3mgSv9WPwZCDxu4rQW1olrI1uml+o= sigs.k8s.io/yaml v1.1.0/go.mod h1:UJmg0vDUVViEyp3mgSv9WPwZCDxu4rQW1olrI1uml+o=
sourcegraph.com/sourcegraph/appdash v0.0.0-20190731080439-ebfcffb1b5c0/go.mod h1:hI742Nqp5OhwiqlzhgfbWU4mW4yO10fP+LoT9WOswdU= sourcegraph.com/sourcegraph/appdash v0.0.0-20190731080439-ebfcffb1b5c0/go.mod h1:hI742Nqp5OhwiqlzhgfbWU4mW4yO10fP+LoT9WOswdU=
xorm.io/builder v0.3.11-0.20220531020008-1bd24a7dc978/go.mod h1:aUW0S9eb9VCaPohFCH3j7czOx1PMW3i1HrSzbLYGBSE= xorm.io/builder v0.3.11-0.20220531020008-1bd24a7dc978/go.mod h1:aUW0S9eb9VCaPohFCH3j7czOx1PMW3i1HrSzbLYGBSE=
xorm.io/builder v0.3.12 h1:ASZYX7fQmy+o8UJdhlLHSW57JDOkM8DNhcAF5d0LiJM= xorm.io/builder v0.3.13 h1:a3jmiVVL19psGeXx8GIurTp7p0IIgqeDmwhcR6BAOAo=
xorm.io/builder v0.3.12/go.mod h1:aUW0S9eb9VCaPohFCH3j7czOx1PMW3i1HrSzbLYGBSE= xorm.io/builder v0.3.13/go.mod h1:aUW0S9eb9VCaPohFCH3j7czOx1PMW3i1HrSzbLYGBSE=
xorm.io/xorm v1.3.2 h1:uTRRKF2jYzbZ5nsofXVUx6ncMaek+SHjWYtCXyZo1oM= xorm.io/xorm v1.3.2 h1:uTRRKF2jYzbZ5nsofXVUx6ncMaek+SHjWYtCXyZo1oM=
xorm.io/xorm v1.3.2/go.mod h1:9NbjqdnjX6eyjRRhh01GHm64r6N9shTb/8Ak3YRt8Nw= xorm.io/xorm v1.3.2/go.mod h1:9NbjqdnjX6eyjRRhh01GHm64r6N9shTb/8Ak3YRt8Nw=

@ -1,5 +1,5 @@
package go_library package go_library
func Version() string { func Version() string {
return "1.0.156" return "1.0.157"
} }

@ -30,6 +30,7 @@ func NewClient(config *ClientConfig) (*Client, error) {
c := &Client{} c := &Client{}
c.config.customer = config.Customer c.config.customer = config.Customer
c.config.key = config.Key
c.requestClient = gorequest.NewHttp() c.requestClient = gorequest.NewHttp()

@ -32,7 +32,7 @@ func (c *Client) request(ctx context.Context, url string, params map[string]inte
client.SetContentTypeForm() client.SetContentTypeForm()
// 设置参数 // 设置参数
client.SetParams(params) client.SetParams(newParams)
// 发起请求 // 发起请求
request, err := client.Request(ctx) request, err := client.Request(ctx)

@ -639,7 +639,7 @@ gorm.io/hints
# gorm.io/plugin/dbresolver v1.4.1 # gorm.io/plugin/dbresolver v1.4.1
## explicit; go 1.14 ## explicit; go 1.14
gorm.io/plugin/dbresolver gorm.io/plugin/dbresolver
# xorm.io/builder v0.3.12 # xorm.io/builder v0.3.13
## explicit; go 1.11 ## explicit; go 1.11
xorm.io/builder xorm.io/builder
# xorm.io/xorm v1.3.2 # xorm.io/xorm v1.3.2

21
vendor/xorm.io/builder/.drone.yml generated vendored

@ -1,21 +0,0 @@
---
kind: pipeline
name: testing
trigger:
ref:
- refs/heads/master
- refs/pull/*/head
steps:
- name: test
pull: default
image: golang:1.11
commands:
- go get -u golang.org/x/lint/golint
- golint ./...
- go vet
- go test -v -race -coverprofile=coverage.txt -covermode=atomic
environment:
GOPROXY: https://goproxy.io
GO111MODULE: "on"

10
vendor/xorm.io/builder/as.go generated vendored

@ -0,0 +1,10 @@
package builder
type Aliased struct {
table interface{}
alias string
}
func As(table interface{}, alias string) *Aliased {
return &Aliased{table, alias}
}

26
vendor/xorm.io/builder/builder.go generated vendored

@ -60,7 +60,7 @@ type Builder struct {
subQuery *Builder subQuery *Builder
cond Cond cond Cond
selects []string selects []string
joins []join joins joins
setOps []setOp setOps []setOp
limitation *limit limitation *limit
insertCols []string insertCols []string
@ -68,7 +68,7 @@ type Builder struct {
updates []UpdateCond updates []UpdateCond
orderBy interface{} orderBy interface{}
groupBy string groupBy string
having string having interface{}
} }
// Dialect sets the db dialect of Builder. // Dialect sets the db dialect of Builder.
@ -113,21 +113,31 @@ func (b *Builder) Where(cond Cond) *Builder {
} }
// From sets from subject(can be a table name in string or a builder pointer) and its alias // From sets from subject(can be a table name in string or a builder pointer) and its alias
func (b *Builder) From(subject interface{}, alias ...string) *Builder { func (b *Builder) From(subject interface{}, aliasMaybe ...string) *Builder {
switch subject.(type) { alias := ""
if len(aliasMaybe) > 0 {
alias = aliasMaybe[0]
}
if aliased, ok := subject.(*Aliased); ok {
subject = aliased.table
alias = aliased.alias
}
switch t := subject.(type) {
case *Builder: case *Builder:
b.subQuery = subject.(*Builder) b.subQuery = t
if len(alias) > 0 { if len(alias) > 0 {
b.from = alias[0] b.from = alias
} else { } else {
b.isNested = true b.isNested = true
} }
case string: case string:
b.from = subject.(string) b.from = t
if len(alias) > 0 { if len(alias) > 0 {
b.from = b.from + " " + alias[0] b.from = b.from + " " + alias
} }
} }

@ -4,6 +4,10 @@
package builder package builder
import (
"fmt"
)
// InnerJoin sets inner join // InnerJoin sets inner join
func (b *Builder) InnerJoin(joinTable, joinCond interface{}) *Builder { func (b *Builder) InnerJoin(joinTable, joinCond interface{}) *Builder {
return b.Join("INNER", joinTable, joinCond) return b.Join("INNER", joinTable, joinCond)
@ -40,3 +44,42 @@ func (b *Builder) Join(joinType string, joinTable, joinCond interface{}) *Builde
return b return b
} }
type joins []join
func (joins joins) WriteTo(w Writer) error {
for _, v := range joins {
var joinTable = v.joinTable
var alias string
if aliased, ok := v.joinTable.(*Aliased); ok {
joinTable = aliased.table
alias = aliased.alias + " "
}
switch tbl := joinTable.(type) {
case *Builder:
if _, err := fmt.Fprintf(w, " %s JOIN (", v.joinType); err != nil {
return err
}
if err := tbl.WriteTo(w); err != nil {
return err
}
if _, err := fmt.Fprintf(w, ") %s", alias); err != nil {
return err
}
case string:
if _, err := fmt.Fprintf(w, " %s JOIN %s %s", v.joinType, tbl, alias); err != nil {
return err
}
}
if _, err := fmt.Fprintf(w, "ON "); err != nil {
return err
}
if err := v.joinCond.WriteTo(w); err != nil {
return err
}
}
return nil
}

@ -19,12 +19,11 @@ func (b *Builder) limitWriteTo(w Writer) error {
if limit.offset < 0 || limit.limitN <= 0 { if limit.offset < 0 || limit.limitN <= 0 {
return ErrInvalidLimitation return ErrInvalidLimitation
} }
// erase limit condition // unset limit condition to prevent final.WriteTo from recursing forever
b.limitation = nil b.limitation = nil
defer func() { defer func() {
b.limitation = limit b.limitation = limit
}() }()
ow := w.(*BytesWriter)
switch strings.ToLower(strings.TrimSpace(b.dialect)) { switch strings.ToLower(strings.TrimSpace(b.dialect)) {
case ORACLE: case ORACLE:
@ -55,19 +54,19 @@ func (b *Builder) limitWriteTo(w Writer) error {
Where(Gt{"att.RN": limit.offset}) Where(Gt{"att.RN": limit.offset})
} }
return final.WriteTo(ow) return final.WriteTo(w)
case SQLITE, MYSQL, POSTGRES: case SQLITE, MYSQL, POSTGRES:
// if type UNION, we need to write previous content back to current writer // if type UNION, we need to write previous content back to current writer
if b.optype == setOpType { if b.optype == setOpType {
if err := b.WriteTo(ow); err != nil { if err := b.WriteTo(w); err != nil {
return err return err
} }
} }
if limit.offset == 0 { if limit.offset == 0 {
fmt.Fprint(ow, " LIMIT ", limit.limitN) fmt.Fprint(w, " LIMIT ", limit.limitN)
} else { } else {
fmt.Fprintf(ow, " LIMIT %v OFFSET %v", limit.limitN, limit.offset) fmt.Fprintf(w, " LIMIT %v OFFSET %v", limit.limitN, limit.offset)
} }
case MSSQL: case MSSQL:
if len(b.selects) == 0 { if len(b.selects) == 0 {
@ -93,7 +92,7 @@ func (b *Builder) limitWriteTo(w Writer) error {
final = Dialect(b.dialect).Select(selects...).From(wb, "at").Where(Gt{"at.RN": limit.offset}) final = Dialect(b.dialect).Select(selects...).From(wb, "at").Where(Gt{"at.RN": limit.offset})
} }
return final.WriteTo(ow) return final.WriteTo(w)
default: default:
return ErrNotSupportType return ErrNotSupportType
} }

@ -79,27 +79,8 @@ func (b *Builder) selectWriteTo(w Writer) error {
} }
} }
for _, v := range b.joins { if err := b.joins.WriteTo(w); err != nil {
b, ok := v.joinTable.(*Builder) return err
if ok {
if _, err := fmt.Fprintf(w, " %s JOIN (", v.joinType); err != nil {
return err
}
if err := b.WriteTo(w); err != nil {
return err
}
if _, err := fmt.Fprintf(w, ") ON "); err != nil {
return err
}
} else {
if _, err := fmt.Fprintf(w, " %s JOIN %s ON ", v.joinType, v.joinTable); err != nil {
return err
}
}
if err := v.joinCond.WriteTo(w); err != nil {
return err
}
} }
if b.cond.IsValid() { if b.cond.IsValid() {
@ -118,9 +99,25 @@ func (b *Builder) selectWriteTo(w Writer) error {
} }
} }
if len(b.having) > 0 { if b.having != nil {
if _, err := fmt.Fprint(w, " HAVING ", b.having); err != nil { switch c := b.having.(type) {
return err case string:
if len(c) > 0 {
if _, err := fmt.Fprint(w, " HAVING ", c); err != nil {
return err
}
}
case Cond:
if c.IsValid() {
if _, err := fmt.Fprint(w, " HAVING "); err != nil {
return err
}
if err := c.WriteTo(w); err != nil {
return err
}
}
default:
return fmt.Errorf("unknown having parameter: %#v", b.having)
} }
} }
@ -166,7 +163,7 @@ func (b *Builder) GroupBy(groupby string) *Builder {
} }
// Having having SQL // Having having SQL
func (b *Builder) Having(having string) *Builder { func (b *Builder) Having(having interface{}) *Builder {
b.having = having b.having = having
return b return b
} }

@ -11,7 +11,7 @@ import (
func (b *Builder) setOpWriteTo(w Writer) error { func (b *Builder) setOpWriteTo(w Writer) error {
if b.limitation != nil || b.cond.IsValid() || if b.limitation != nil || b.cond.IsValid() ||
b.orderBy != nil || b.having != "" || b.groupBy != "" { b.orderBy != nil || b.having != nil || b.groupBy != "" {
return ErrNotUnexpectedUnionConditions return ErrNotUnexpectedUnionConditions
} }

Loading…
Cancel
Save