Compare commits
4 commits
6a21576c1c
...
e09a3f1d55
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
e09a3f1d55 | ||
|
|
944d9482fd | ||
|
|
b3df73d595 | ||
|
|
ad880b3fb4 |
2 changed files with 13 additions and 3 deletions
4
.gitignore
vendored
4
.gitignore
vendored
|
|
@ -1,3 +1,7 @@
|
||||||
.idea
|
.idea
|
||||||
.env
|
.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
|
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)
|
taskMap := make(map[string]shared.Task)
|
||||||
|
|
||||||
for _, item := range getLinks.Surugaya {
|
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
|
return taskMap, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -102,12 +108,12 @@ func (p *TaskProvider) InsertPrices(prices []shared.TaskResult) error {
|
||||||
|
|
||||||
func (r *TaskRepo) getLinks() (*Link, error) {
|
func (r *TaskRepo) getLinks() (*Link, error) {
|
||||||
var surugayaList []Surugaya
|
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
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
var mandarakeList []Mandarake
|
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
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue