diff --git a/app/task/svc/svc_data_collect_cron_miyuan_real_news.go b/app/task/svc/svc_data_collect_cron_miyuan_real_news.go index 942bc5e..d60ca1a 100644 --- a/app/task/svc/svc_data_collect_cron_miyuan_real_news.go +++ b/app/task/svc/svc_data_collect_cron_miyuan_real_news.go @@ -15,8 +15,8 @@ import ( func DataCollectCronMiyuanRealNews(types int) { key := md.ZhiosRealNewsData //es.CreateIndexIfNotExists(key, md.ZhiosRealNewsDataField) - ids := []string{"MC", "TM", "JD", "PDD", "CD", "ZD", "MS", "QYH"} - ids = []string{"JD"} + ids := []string{"MC", "TM", "JD", "PDD", "CD", "ZD", "MS", "QYH", "TM", "BJ", "HJ"} + //ids = []string{"CD"} num := 10 if types == 0 { ids = []string{""} @@ -32,7 +32,7 @@ func DataCollectCronMiyuanRealNews(types int) { if newsData == nil || err != nil { continue } - platformMap := map[string]string{"MC": "10001", "TM": "10003", "JD": "10004", "PDD": "10005", "CD": "10006", "ZD": "10002", "MS": "10007", "QYH": "10000"} + platformMap := map[string]string{"TM": "10010", "BJ": "10009", "HJ": "10008", "MC": "10001", "TB": "10003", "JD": "10004", "PDD": "10005", "CD": "10006", "ZD": "10002", "MS": "10007", "QYH": "10000"} for _, item := range newsData { var tmp = md2.RealNewsData{ Id: item.Id,