合并查研观向与策略平台的阅读记录到一张表

models/article_history_record_newpv.go

@@ -154,7 +154,7 @@ func GetArticleHistoryRecordAllList() (items []*CygxArticleHistoryRecordNewpv, e
 	sql := ` SELECT * FROM cygx_article_history_record_all WHERE create_time >= date(NOW()) 
 			AND mobile <> '' 
 			AND platfor = 1
-			GROUP BYmobile,article_id `
+			GROUP BY mobile,article_id `
 	_, err = o.Raw(sql).QueryRows(&items)
 	return
 }

services/article.go

@@ -917,17 +917,17 @@ func GetCeLueArticlePv(cont context.Context) (err error) {
 		return err
 	}
 	mapMobileArticleId := make(map[string]int)
-
-	listPv, err := models.GetArticleHistoryList()
+	//获取当天阅读记录
+	listPv, err := models.GetArticleHistoryRecordAllList()
 	if err != nil && err.Error() != utils.ErrNoRow() {
 		fmt.Println("获取当天阅读记录失败", err)
+		return err
 	}
 	if len(listPv) > 0 {
 		for _, v := range listPv {
-			mapMobileArticleId[fmt.Sprint(v.Mobile, v.ArticleId)] = v.ArticleId
+			mapMobileArticleId[fmt.Sprint(v.Mobile, "_", v.ArticleId)] = v.ArticleId
 		}
 	}
-
 	for _, v := range chartResult.Data {
 		//fmt.Println(v.ArticleId)
 		item := new(models.CygxCelueArticleHistoryRecord)

services/task.go

@@ -22,9 +22,6 @@ func Task() {
 		getArticleListByApi := task.NewTask("getArticleListByApi", "0 */5 * * * *", GetArticleListByApi) //通过三方接口获取策略平台上的文章
 		task.AddTask("getArticleListByApi", getArticleListByApi)
 
-		getCeLueArticlePv := task.NewTask("getCeLueArticlePv", "0 */10 * * * *", GetCeLueArticlePv) //通过三方接口获取策略平台上的阅读记录
-		task.AddTask("getCeLueArticlePv", getCeLueArticlePv)
-
 		//会议提醒模板消息推送
 		sendActivityBeginMsg := task.NewTask("sendActivityBeginMsg", "0 */10 8-22 * * *", SendActivityBeginMsg) //会议前60分钟的提醒
 		task.AddTask("sendActivityBeginMsg", sendActivityBeginMsg)
@@ -71,6 +68,9 @@ func Task() {
 
 		updateWxUserLabel := task.NewTask("updateWxUserLabel", "0 50 3 * * *", UpdateWxUserLabel) //更新用户的标签
 		task.AddTask("updateWxUserLabel", updateWxUserLabel)
+
+		getCeLueArticlePv := task.NewTask("getCeLueArticlePv", "0 */10 * * * *", GetCeLueArticlePv) //通过三方接口获取策略平台上的阅读记录
+		task.AddTask("getCeLueArticlePv", getCeLueArticlePv)
 	}
 	if utils.RunMode != "release" {
 		getArticleListByApi := task.NewTask("getArticleListByApi", "0 */60 * * * *", GetArticleListByApi) //通过三方接口获取策略平台上的文章