添加销售明细推送到wms

liujiandao

2024-01-11 40e540f8ca398fee68f4520dbebd6db6fe2e164c

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
package model
 
import (
    "aps_crm/pkg/mysqlx"
    "gorm.io/gorm"
    "sync"
)
 
type (
    // ClientStatus 客户状态
    ClientStatus struct {
        Id   int    `json:"id" gorm:"column:id;primary_key;AUTO_INCREMENT"`
        Name string `json:"name" gorm:"column:name;type:varchar(255);comment:客户状态名称"`
    }
 
    // ClientStatusSearch 客户状态搜索条件
    ClientStatusSearch struct {
        ClientStatus
        Orm *gorm.DB
    }
)
 
func (ClientStatus) TableName() string {
    return "client_status"
}
 
func NewClientStatusSearch() *ClientStatusSearch {
    return &ClientStatusSearch{
        Orm: mysqlx.GetDB(),
    }
}
 
func (slf *ClientStatusSearch) build() *gorm.DB {
    var db = slf.Orm.Model(&ClientStatus{})
    if slf.Id != 0 {
        db = db.Where("id = ?", slf.Id)
    }
    if slf.Name != "" {
        db = db.Where("name = ?", slf.Name)
    }
 
    return db
}
 
func (slf *ClientStatusSearch) Create(record *ClientStatus) error {
    var db = slf.build()
    return db.Create(record).Error
}
 
func (slf *ClientStatusSearch) Delete() error {
    var db = slf.build()
    return db.Delete(&ClientStatus{}).Error
}
 
func (slf *ClientStatusSearch) Update(record *ClientStatus) error {
    var db = slf.build()
    return db.Updates(record).Error
}
 
func (slf *ClientStatusSearch) Find() (*ClientStatus, error) {
    var db = slf.build()
    var record = new(ClientStatus)
    err := db.First(record).Error
    return record, err
}
 
func (slf *ClientStatusSearch) FindAll() ([]*ClientStatus, error) {
    var db = slf.build()
    var record = make([]*ClientStatus, 0)
    err := db.Find(&record).Error
    return record, err
}
 
func (slf *ClientStatusSearch) SetId(id int) *ClientStatusSearch {
    slf.Id = id
    return slf
}
 
func (slf *ClientStatusSearch) SetName(name string) *ClientStatusSearch {
    slf.Name = name
    return slf
}
 
func (slf *ClientStatusSearch) First() (*ClientStatus, error) {
    var db = slf.build()
    var record = new(ClientStatus)
    err := db.First(record).Error
    return record, err
}
 
func (slf *ClientStatusSearch) Updates(values interface{}) error {
    var db = slf.build()
    return db.Updates(values).Error
}
 
func (slf *ClientStatusSearch) CreateBatch(records []*ClientStatus) error {
    var db = slf.build()
    return db.Create(records).Error
}
 
// InitDefaultData 初始化数据
func (slf *ClientStatusSearch) InitDefaultData(errCh chan<- error, wg *sync.WaitGroup) {
    var (
        db          = slf.Orm.Table(slf.TableName())
        total int64 = 0
    )
    defer wg.Done()
    if err := db.Count(&total).Error; err != nil {
        errCh <- err
        return
    }
    if total != 0 {
        return
    }
    records := []*ClientStatus{
        {1, "初期沟通"},
        {2, "需求分析"},
        {3, "方案报价"},
        {4, "商务谈判"},
        {5, "成功结案"},
    }
 
    err := slf.CreateBatch(records)
    if err != nil {
        errCh <- err
        return
    }
}