Compare commits
4 commits
6a21576c1c
...
e09a3f1d55
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
e09a3f1d55 | ||
|
|
944d9482fd | ||
|
|
b3df73d595 | ||
|
|
ad880b3fb4 |
2 changed files with 13 additions and 3 deletions
6
.gitignore
vendored
6
.gitignore
vendored
|
|
@ -1,3 +1,7 @@
|
|||
.idea
|
||||
.env
|
||||
/config/devConfig.go
|
||||
/config/devConfig.go
|
||||
*.sh
|
||||
!gen-swag.sh
|
||||
.directory
|
||||
*.tar
|
||||
|
|
|
|||
|
|
@ -42,6 +42,11 @@ func (p *TaskProvider) PrepareTasks() (map[string]shared.Task, error) {
|
|||
return nil, err
|
||||
}
|
||||
|
||||
log.WithFields(log.Fields{
|
||||
"surugaya links": len(getLinks.Surugaya),
|
||||
"mandarake links": len(getLinks.Mandarake),
|
||||
}).Info("gRPC Server | Prepare tasks")
|
||||
|
||||
taskMap := make(map[string]shared.Task)
|
||||
|
||||
for _, item := range getLinks.Surugaya {
|
||||
|
|
@ -67,6 +72,7 @@ func (p *TaskProvider) PrepareTasks() (map[string]shared.Task, error) {
|
|||
}
|
||||
}
|
||||
}
|
||||
log.WithField("data", taskMap).Debug("Prepare tasks")
|
||||
return taskMap, nil
|
||||
}
|
||||
|
||||
|
|
@ -102,12 +108,12 @@ func (p *TaskProvider) InsertPrices(prices []shared.TaskResult) error {
|
|||
|
||||
func (r *TaskRepo) getLinks() (*Link, error) {
|
||||
var surugayaList []Surugaya
|
||||
if err := r.db.Model(&Surugaya{}).Find(&surugayaList).Error; err != nil {
|
||||
if err := r.db.Model(&Surugaya{}).Where("deleted_at IS NULL").Find(&surugayaList).Error; err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
var mandarakeList []Mandarake
|
||||
if err := r.db.Model(&Mandarake{}).Find(&mandarakeList).Error; err != nil {
|
||||
if err := r.db.Model(&Mandarake{}).Where("deleted_at IS NULL").Find(&mandarakeList).Error; err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue