添加默认数据

zhangqian

2023-10-17 63b531279a8ab1d609910e7db53add83bbc0b97a

添加默认数据

 model/bankAccount.go

@@ -6,24 +6,25 @@
    "errors"
    "fmt"
    "gorm.io/gorm"
    "sync"
)

type (
    // BankAccount 银行账户
    BankAccount struct {
        Id   int    `json:"id" gorm:"column:id;primary_key;AUTO_INCREMENT"`
        Name   string    `json:"name" gorm:"column:name"`
        Name string `json:"name" gorm:"column:name"`
    }

    // BankAccountSearch 银行账户搜索条件
    BankAccountSearch struct {
        BankAccount
        Orm *gorm.DB
        QueryClass  constvar.BankAccountQueryClass
        KeywordType constvar.BankAccountKeywordType
        Keyword     string
        PageNum  int
        PageSize int
        Orm         *gorm.DB
        QueryClass  constvar.BankAccountQueryClass
        KeywordType constvar.BankAccountKeywordType
        Keyword     string
        PageNum     int
        PageSize    int
    }
)

@@ -124,17 +125,26 @@
}

// InitDefaultData 初始化数据
func (slf *BankAccountSearch) InitDefaultData() error {
func (slf *BankAccountSearch) 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 {
        return err
        errCh <- err
        return
    }
    if total != 0 {
        return nil
        return
    }
    records := []*BankAccount{}
    return slf.CreateBatch(records)
    records := []*BankAccount{
        {1, "默认账户"},
    }
    err := slf.CreateBatch(records)
    if err != nil {
        errCh <- err
        return
    }
}

 model/clientLevel.go

@@ -3,6 +3,7 @@
import (
    "aps_crm/pkg/mysqlx"
    "gorm.io/gorm"
    "sync"
)

type (
@@ -82,3 +83,36 @@
    var db = slf.build()
    return db.Updates(data).Error
}

func (slf *ClientLevelSearch) CreateBatch(records []*ClientLevel) error {
    var db = slf.build()
    return db.Create(records).Error
}

// InitDefaultData 初始化数据
func (slf *ClientLevelSearch) 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 := []*ClientLevel{
        {1, "重点关注客户"},
        {2, "优质客户"},
        {3, "普通客户"},
        {4, "其他"},
    }
    err := slf.CreateBatch(records)
    if err != nil {
        errCh <- err
        return
    }
}

 model/clientOrigin.go

@@ -3,6 +3,7 @@
import (
    "aps_crm/pkg/mysqlx"
    "gorm.io/gorm"
    "sync"
)

type (
@@ -89,3 +90,38 @@
    var db = slf.build()
    return db.Updates(data).Error
}

func (slf *ClientOriginSearch) CreateBatch(records []*ClientOrigin) error {
    var db = slf.build()
    return db.Create(records).Error
}

// InitDefaultData 初始化数据
func (slf *ClientOriginSearch) 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 := []*ClientOrigin{
        {1, "供应商资源"},
        {2, "客户介绍"},
        {3, "现有客户"},
        {4, "展会"},
        {5, "外出拜访客户"},
        {6, "其他"},
    }
    err := slf.CreateBatch(records)
    if err != nil {
        errCh <- err
        return
    }
}

 model/clientType.go

@@ -3,6 +3,7 @@
import (
    "aps_crm/pkg/mysqlx"
    "gorm.io/gorm"
    "sync"
)

type (
@@ -91,3 +92,36 @@
    var db = slf.build()
    return db.Updates(data).Error
}

func (slf *ClientTypeSearch) CreateBatch(records []*ClientType) error {
    var db = slf.build()
    return db.Create(records).Error
}

// InitDefaultData 初始化数据
func (slf *ClientTypeSearch) 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 := []*ClientType{
        {1, "代理商"},
        {2, "集成商"},
        {3, "合作伙伴"},
        {4, "其他"},
    }
    err := slf.CreateBatch(records)
    if err != nil {
        errCh <- err
        return
    }
}

 model/contactInformation.go

@@ -3,6 +3,7 @@
import (
    "aps_crm/pkg/mysqlx"
    "gorm.io/gorm"
    "sync"
)

type (
@@ -78,3 +79,35 @@
    slf.Name = name
    return slf
}

func (slf *ContactInformationSearch) CreateBatch(records []*ContactInformation) error {
    var db = slf.build()
    return db.Create(records).Error
}

// InitDefaultData 初始化数据
func (slf *ContactInformationSearch) 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 := []*ContactInformation{
        {1, "线下拜访"},
        {2, "电话联系"},
        {3, "会议"},
    }
    err := slf.CreateBatch(records)
    if err != nil {
        errCh <- err
        return
    }
}

 model/enterpriseNature.go

@@ -3,6 +3,7 @@
import (
    "aps_crm/pkg/mysqlx"
    "gorm.io/gorm"
    "sync"
)

type (
@@ -84,3 +85,39 @@
    var db = slf.build()
    return db.Updates(data).Error
}

func (slf *EnterpriseNatureSearch) CreateBatch(records []*EnterpriseNature) error {
    var db = slf.build()
    return db.Create(records).Error
}

// InitDefaultData 初始化数据
func (slf *EnterpriseNatureSearch) 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 := []*EnterpriseNature{
        {1, "国有企业"},
        {2, "集体企业"},
        {3, "私营企业"},
        {4, "个体工商户"},
        {5, "合伙企业"},
        {6, "联营企业"},
        {7, "股份合作制企业"},
    }
    err := slf.CreateBatch(records)
    if err != nil {
        errCh <- err
        return
    }
}

 model/enterpriseScale.go

@@ -3,6 +3,7 @@
import (
    "aps_crm/pkg/mysqlx"
    "gorm.io/gorm"
    "sync"
)

type (
@@ -86,3 +87,38 @@
    slf.Id = id
    return slf
}

func (slf *EnterpriseScaleSearch) CreateBatch(records []*EnterpriseScale) error {
    var db = slf.build()
    return db.Create(records).Error
}

// InitDefaultData 初始化数据
func (slf *EnterpriseScaleSearch) 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 := []*EnterpriseScale{
        {1, "20人以下"},
        {2, "20-50人"},
        {3, "50-100人"},
        {4, "100-500人"},
        {5, "500-1000人"},
        {6, "1000人以上"},
    }
    err := slf.CreateBatch(records)
    if err != nil {
        errCh <- err
        return
    }
}

 model/index.go

@@ -126,6 +126,19 @@
        NewQuotationStatusSearch(),
        NewSalesSourcesSearch(),
        NewClientStatusSearch(),
        NewClientTypeSearch(),
        NewClientOriginSearch(),
        NewClientLevelSearch(),
        NewIndustrySearch(),
        NewRegisteredCapitalSearch(),
        NewEnterpriseNatureSearch(),
        NewEnterpriseScaleSearch(),
        NewContactInformationSearch(),
        NewSaleTypeSearch(),
        NewPossibilitySearch(),
        NewStatusSearch(),
        NewPaymentTypeSearch(),
        NewBankAccountSearch(),
    }

    for _, model := range models {

 model/industry.go

@@ -3,6 +3,7 @@
import (
    "aps_crm/pkg/mysqlx"
    "gorm.io/gorm"
    "sync"
)

type (
@@ -84,3 +85,38 @@
    var db = slf.build()
    return db.Updates(data).Error
}

func (slf *IndustrySearch) CreateBatch(records []*Industry) error {
    var db = slf.build()
    return db.Create(records).Error
}

// InitDefaultData 初始化数据
func (slf *IndustrySearch) 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 := []*Industry{
        {1, "制造业"},
        {2, "交通运输"},
        {3, "建筑业"},
        {4, "环境和公共设施管理业"},
        {5, "批发和零售业"},
        {6, "其他"},
    }
    err := slf.CreateBatch(records)
    if err != nil {
        errCh <- err
        return
    }
}

 model/paymentType.go

@@ -6,24 +6,25 @@
    "errors"
    "fmt"
    "gorm.io/gorm"
    "sync"
)

type (
    // PaymentType 支付方式
    PaymentType struct {
        Id   int    `json:"id" gorm:"column:id;primary_key;AUTO_INCREMENT"`
        Name   string    `json:"name" gorm:"column:name"`
        Name string `json:"name" gorm:"column:name"`
    }

    // PaymentTypeSearch 支付方式搜索条件
    PaymentTypeSearch struct {
        PaymentType
        Orm *gorm.DB
        QueryClass  constvar.PaymentTypeQueryClass
        KeywordType constvar.PaymentTypeKeywordType
        Keyword     string
        PageNum  int
        PageSize int
        Orm         *gorm.DB
        QueryClass  constvar.PaymentTypeQueryClass
        KeywordType constvar.PaymentTypeKeywordType
        Keyword     string
        PageNum     int
        PageSize    int
    }
)

@@ -124,17 +125,28 @@
}

// InitDefaultData 初始化数据
func (slf *PaymentTypeSearch) InitDefaultData() error {
func (slf *PaymentTypeSearch) 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 {
        return err
        errCh <- err
        return
    }
    if total != 0 {
        return nil
        return
    }
    records := []*PaymentType{}
    return slf.CreateBatch(records)
    records := []*PaymentType{
        {1, "原路返回"},
        {2, "线下"},
        {3, "支票"},
    }
    err := slf.CreateBatch(records)
    if err != nil {
        errCh <- err
        return
    }
}

 model/possibilities.go

@@ -3,6 +3,7 @@
import (
    "aps_crm/pkg/mysqlx"
    "gorm.io/gorm"
    "sync"
)

type (
@@ -84,3 +85,42 @@
    var db = slf.build()
    return db.Updates(data).Error
}

func (slf *PossibilitySearch) CreateBatch(records []*Possibility) error {
    var db = slf.build()
    return db.Create(records).Error
}

// InitDefaultData 初始化数据
func (slf *PossibilitySearch) 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 := []*Possibility{
        {1, "100%"},
        {2, "90%"},
        {3, "80%"},
        {4, "70%"},
        {5, "60%"},
        {6, "50%"},
        {7, "40%"},
        {8, "30%"},
        {9, "20%"},
        {10, "10%"},
    }
    err := slf.CreateBatch(records)
    if err != nil {
        errCh <- err
        return
    }
}

 model/registeredCapital.go

@@ -3,6 +3,7 @@
import (
    "aps_crm/pkg/mysqlx"
    "gorm.io/gorm"
    "sync"
)

type (
@@ -82,3 +83,37 @@
    slf.Name = name
    return slf
}

func (slf *RegisteredCapitalSearch) CreateBatch(records []*RegisteredCapital) error {
    var db = slf.build()
    return db.Create(records).Error
}

// InitDefaultData 初始化数据
func (slf *RegisteredCapitalSearch) 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 := []*RegisteredCapital{
        {1, "50万以下"},
        {2, "50-100万"},
        {3, "100-500万"},
        {4, "500-1000万"},
        {5, "1000万以上"},
    }
    err := slf.CreateBatch(records)
    if err != nil {
        errCh <- err
        return
    }
}

 model/saleChance.go

@@ -30,6 +30,7 @@
        Currency              int                    `json:"currency" gorm:"column:currency;type:int(11);comment:币种"`
        ExpectedTime          *CustomTime            `json:"expected_time" gorm:"column:expected_time;type:datetime;comment:预计成交时间"`
        StatusId              int                    `json:"status_id" gorm:"column:status_id;type:int(11);comment:状态ID"`
        Status                Status                 `json:"status_id" gorm:"column:status_id;type:int(11);comment:状态ID"`
        PainPoints            string                 `json:"pain_points" gorm:"column:pain_points;type:text;comment:痛点"`
        WhetherEstablished    string                 `json:"whether_established" gorm:"column:whether_established;type:text;comment:是否成立"`
        CapitalBudget         string                 `json:"capital_budget" gorm:"column:capital_budget;type:text;comment:资金预算"`
@@ -163,7 +164,7 @@
    err := db.Preload("SaleType").Preload("RegularCustomers").Preload("SalesSources").
        Preload("Member").Preload("SaleStage").Preload("Possibility").
        Preload("CollectionProjections").Preload("Client").
        Preload("Province").Preload("City").Preload("Contact").Order("id desc").Find(&records).Error
        Preload("Province").Preload("City").Preload("Contact").Preload("Status").Order("id desc").Find(&records).Error
    return records, total, err
}


 model/saleType.go

@@ -3,6 +3,7 @@
import (
    "aps_crm/pkg/mysqlx"
    "gorm.io/gorm"
    "sync"
)

type (
@@ -82,3 +83,34 @@
    var db = slf.build()
    return db.Updates(data).Error
}

func (slf *SaleTypeSearch) CreateBatch(records []*SaleType) error {
    var db = slf.build()
    return db.Create(records).Error
}

// InitDefaultData 初始化数据
func (slf *SaleTypeSearch) 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 := []*SaleType{
        {1, "新业务"},
        {2, "传统业务"},
    }
    err := slf.CreateBatch(records)
    if err != nil {
        errCh <- err
        return
    }
}

 model/status.go

@@ -3,6 +3,7 @@
import (
    "aps_crm/pkg/mysqlx"
    "gorm.io/gorm"
    "sync"
)

type (
@@ -84,3 +85,34 @@
    var db = slf.build()
    return db.Updates(data).Error
}

func (slf *StatusSearch) CreateBatch(records []*Status) error {
    var db = slf.build()
    return db.Create(records).Error
}

// InitDefaultData 初始化数据
func (slf *StatusSearch) 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 := []*Status{
        {1, "已成交"},
        {2, "未成交"},
    }
    err := slf.CreateBatch(records)
    if err != nil {
        errCh <- err
        return
    }
}