|
@@ -948,6 +948,7 @@ func UpStateAndUpSpider(code, id, reason, username string, state int) (bool, err
|
|
// upresult = true
|
|
// upresult = true
|
|
// }
|
|
// }
|
|
upresult, err = spider.UpdateSpiderByCodeState(code, fmt.Sprint(state), event) //下架
|
|
upresult, err = spider.UpdateSpiderByCodeState(code, fmt.Sprint(state), event) //下架
|
|
|
|
+ qu.Debug("下架:", upresult, code)
|
|
case Sp_state_5: //上架(爬虫端在更新上架的时候为了更新内存中字段,采用先下架在上架)
|
|
case Sp_state_5: //上架(爬虫端在更新上架的时候为了更新内存中字段,采用先下架在上架)
|
|
upresult, err = spider.UpdateSpiderByCodeState(code, "6", event)
|
|
upresult, err = spider.UpdateSpiderByCodeState(code, "6", event)
|
|
qu.Debug("下架:", upresult, code)
|
|
qu.Debug("下架:", upresult, code)
|
|
@@ -1315,6 +1316,7 @@ func (f *Front) Heart() {
|
|
orderType = -1
|
|
orderType = -1
|
|
}
|
|
}
|
|
sort = fmt.Sprintf(sort, orderName, orderType)
|
|
sort = fmt.Sprintf(sort, orderName, orderType)
|
|
|
|
+ qu.Debug("query:", query, "sort:", sort)
|
|
list := *mgu.Find("spider_heart", "spider", "spider", query, sort, nil, false, start, limit)
|
|
list := *mgu.Find("spider_heart", "spider", "spider", query, sort, nil, false, start, limit)
|
|
count := mgu.Count("spider_heart", "spider", "spider", query)
|
|
count := mgu.Count("spider_heart", "spider", "spider", query)
|
|
for _, l := range list {
|
|
for _, l := range list {
|