@@ -121,7 +121,7 @@ func RefreshDataFromPb(wg *sync.WaitGroup) (err error) {
}()
var condition string
var pars []interface{}
- condition += " AND source=? "
+ condition += " AND source=? AND frequency in ('日度','周度') "
pars = append(pars, utils.DATA_SOURCE_PB)
items, err := data_manage.GetEdbInfoByCondition(condition, pars, 0)