|
@@ -674,17 +674,17 @@ func GetArticleListByApi(cont context.Context) (err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-func init() {
|
|
|
- // allList, err := models.GetArticleAll()
|
|
|
- //
|
|
|
- // fmt.Println(err)
|
|
|
- //
|
|
|
- // for _, v := range allList {
|
|
|
- // HandleArticleListByApi(v.ArticleId)
|
|
|
- // }
|
|
|
- HandleArticleListByApi(8340)
|
|
|
+//func init() {
|
|
|
+// allList, err := models.GetArticleAll()
|
|
|
+//
|
|
|
+// fmt.Println(err)
|
|
|
+//
|
|
|
+// for _, v := range allList {
|
|
|
+// HandleArticleListByApi(v.ArticleId)
|
|
|
+// }
|
|
|
+//HandleArticleListByApi(8112)
|
|
|
|
|
|
-}
|
|
|
+//}
|
|
|
|
|
|
// 处理同步过来的文章
|
|
|
func HandleArticleListByApi(artcleId int) (err error) {
|
|
@@ -1166,15 +1166,17 @@ func HandleArticleListByApi(artcleId int) (err error) {
|
|
|
}
|
|
|
|
|
|
//func init() {
|
|
|
-// DoArticleOnenIdWxTemplateMsg(4042)
|
|
|
+// DoArticleOnenIdWxTemplateMsg(8112)
|
|
|
//}
|
|
|
|
|
|
// 过滤策略平台报告,研选报告重复推送,以及权限勾选的推送
|
|
|
func DoArticleOnenIdWxTemplateMsg(articleId int) (err error) {
|
|
|
+
|
|
|
//策略平台同步过来的文章ID,做微信模板消息推送,同一篇报告12小时只推送一次
|
|
|
cacheKey := fmt.Sprint(utils.CACHE_KEY_ARTICLE_ID_TEMPLATE, ":ArticleId", articleId)
|
|
|
ttlTime := utils.Rc.GetRedisTTL(cacheKey)
|
|
|
if ttlTime > 0 {
|
|
|
+ fmt.Println(ttlTime)
|
|
|
return err
|
|
|
}
|
|
|
var msg string
|
|
@@ -1322,8 +1324,8 @@ func DoArticleOnenIdWxTemplateMsg(articleId int) (err error) {
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
- //行业综述报告,对所有开通了对应行业权限的客户都推送。
|
|
|
- if articleInfo.ReportType == 1 {
|
|
|
+ //四大行业的行业综述报告,对所有开通了对应行业权限的客户都推送。
|
|
|
+ if articleInfo.ReportType == 1 && chartPermissionId != utils.CE_LUE_ID && chartPermissionId != utils.GU_SHOU_ID {
|
|
|
for _, item := range openidPowerList {
|
|
|
first := "您关注的赛道,有新的报告发布/更新,欢迎查看"
|
|
|
keyword1 := "所属赛道:" + articleInfo.SubCategoryName
|
|
@@ -1334,7 +1336,6 @@ func DoArticleOnenIdWxTemplateMsg(articleId int) (err error) {
|
|
|
}
|
|
|
return err
|
|
|
}
|
|
|
-
|
|
|
for _, v := range openidPowerList {
|
|
|
mapOpenidPower[v.UserId] = v.OpenId
|
|
|
}
|
|
@@ -1565,7 +1566,7 @@ func GetSpecialArticleDetailUserPower(user *models.WxUserItem, articleInfo *mode
|
|
|
return
|
|
|
}
|
|
|
if reportMapDetail == nil {
|
|
|
- err = errors.New("GetdetailByCategoryIdP,获取详情失败, Err: " + e.Error())
|
|
|
+ err = errors.New("GetdetailByCategoryIdP,获取详情失败, ")
|
|
|
return
|
|
|
}
|
|
|
fmt.Println(permissionStr)
|