diff --git a/internal/parser/parser.go b/internal/parser/parser.go index e0c36e0..386d2fc 100644 --- a/internal/parser/parser.go +++ b/internal/parser/parser.go @@ -41,7 +41,7 @@ func NewParser(cfg config.Parser, delay time.Duration, randomDelay time.Duration func (p *Parser) Run(ch chan feed.Entry, fp *gofeed.Parser, wg *sync.WaitGroup) { - log.Printf("🚩 run parser with params: delay: %v, random delay: %v, url: %v", p.Delay, p.RandomDelay, p.Link.Url) + log.Printf("🚩 run parser: delay: %v, random delay: %v, url: %v", p.Delay, p.RandomDelay, p.Link.Url) defer wg.Done() diff --git a/internal/workerpool/task.go b/internal/workerpool/task.go index 64c9ebf..9a45c3f 100644 --- a/internal/workerpool/task.go +++ b/internal/workerpool/task.go @@ -230,16 +230,13 @@ func needUpdate(dbe *feed.Entry, e feed.Entry) bool { return true } - //intervalT := dbeTime.Add(1 * time.Hour) - //log.Printf("dbeTime.Add(1*time.Hour), %v\n", intervalT) - //log.Printf("current eTime, %v\n", eTime) - //log.Printf("Sub(eTime), %v\n", intervalT.Sub(eTime)) - - //Для ленты сайта mid + //Для ленты сайта mid language ru if dbeTime.Add(1*time.Hour).Sub(eTime) <= 0 && dbe.ResourceID == 2 { - log.Printf("dbeTime.Add(1*time.Hour).Sub(eTime) <= 0 && dbe.ResourceID == 2, condition id true") - log.Printf("🚩 Url %v `updated` fields do not match dbe updated dbe: %v, e: %v ", dbe.Url, dbeTime, eTime) - return true + if dbe.Language == "ru" { + log.Printf("dbeTime.Add(1*time.Hour).Sub(eTime) <= 0 && dbe.ResourceID == 2, lang ru, condition id true") + log.Printf("🚩 Url %v `updated` fields do not match dbe updated dbe: %v, e: %v ", dbe.Url, dbeTime, eTime) + return true + } } return false