fix

controllers/yanxuan_special.go

@@ -3,6 +3,7 @@ package controllers
 import (
 	"encoding/json"
 	"hongze/hongze_cygx/models"
+	"hongze/hongze_cygx/services"
 	"hongze/hongze_cygx/utils"
 	"time"
 )
@@ -394,7 +395,9 @@ func (this *YanxuanSpecialController) Enable() {
 		br.ErrMsg = "审批失败, Err:" + tmpErr.Error()
 		return
 	}
-
+	if req.Status == 1 {
+		go services.SendWxMsgSpecialFollow(req.Id)
+	}
 	br.Msg = "审批成功"
 	br.Ret = 200
 	br.Success = true

models/cygx_yanxuan_special_follow.go

@@ -39,3 +39,19 @@ func DelCygxYanxuanSpecialFollow(userId, followUserId int) (err error) {
 	_, err = o.Raw(sql, userId, followUserId).Exec()
 	return
 }
+
+func GetCygxYanxuanSpecialFollowOpenIdList(followUserId int) (items []*OpenIdList, err error) {
+	o := orm.NewOrm()
+	sql := `SELECT
+	cr.*,
+	c.user_id 
+FROM
+	user_record AS c
+	INNER JOIN cygx_user_record AS cr ON cr.union_id = c.union_id
+	INNER JOIN cygx_yanxuan_special_follow AS cf ON cf.user_id = c.user_id 
+	AND cf.follow_user_id = ? 
+WHERE
+	create_platform = 4 `
+	_, err = o.Raw(sql, followUserId).QueryRows(&items)
+	return
+}

models/report.go

@@ -1066,6 +1066,7 @@ type ArticleReportBillboardResp struct {
 	SpecialTags     string `description:"研选专栏标签"`
 	MyCollectNum    int    `description:"本人是否收藏"`
 	SpecialType     int    `description:"专栏类型 1:笔记，2:观点"`
+	UserId          int    `description:"作者id"`
 	List            []*IndustrialManagementIdInt
 }
 

models/user.go

@@ -182,6 +182,7 @@ func GetArticleUserCollectList(startSize, pageSize, userId int) (items []*Articl
 		0 AS collect_num,
 		0 AS my_collect_num,
 		0 AS special_type,
+		a.user_id AS user_id,
 		a.create_time AS create_time 
 			FROM cygx_article_collect AS a 
 			INNER JOIN cygx_article as art ON art.article_id = a.article_id
@@ -201,6 +202,7 @@ func GetArticleUserCollectList(startSize, pageSize, userId int) (items []*Articl
 		( SELECT count( 1 ) FROM cygx_yanxuan_special_collect AS ac  INNER JOIN wx_user as u ON  u.user_id = ac.user_id  WHERE ac.yanxuan_special_id = a.id  ) AS collect_num,
 		( SELECT count( 1 ) FROM cygx_yanxuan_special_collect AS ac WHERE ac.yanxuan_special_id = a.id  AND user_id = ? ) AS my_collect_num,
 		a.type AS special_type,
+		a.user_id AS user_id,
 		c.create_time AS create_time 
 	FROM
 	cygx_yanxuan_special AS a

services/cygx_yanxuan_special.go

@@ -0,0 +1,68 @@
+package services
+
+// 选专栏有新内容审核通过时，给关注此专栏的客户发送模板消息
+func SendWxMsgSpecialFollow(specialId int) (err error) {
+	//var msg string
+	//defer func() {
+	//	if err != nil {
+	//		go utils.SendEmail("发送模版消息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
+	//		go utils.SendAlarmMsg(fmt.Sprint("预报名活动，感兴趣人数满10人时，推送给活动负责人和王芳消息发送失败", activityInfo.ResearchTheme, ", activityId"), 2)
+	//		utils.FileLog.Info("发送模版消息失败,Err:%s", err.Error())
+	//	}
+	//}()
+	//var first string
+	//var keyword1 string
+	//var keyword2 string
+	//var keyword3 string
+	//var keyword4 string
+	//var remark string
+	//
+	//adminUser, e := models.GetSellerByAdminId(activityInfo.AdminId)
+	//if e != nil {
+	//	err = errors.New("GetSellerByAdminId, Err: " + e.Error())
+	//	return
+	//}
+	//cnf, _ := models.GetConfigByCode("tpl_msg")
+	//mobile := adminUser.Mobile + "," + cnf.ConfigValue
+	//
+	//specialSignupList, e := models.GetActivityListSpecialByActivityId(activityId)
+	//if e != nil {
+	//	err = errors.New("GetActivityListSpecialAll, Err: " + e.Error())
+	//	return
+	//}
+	//for _, v := range specialSignupList {
+	//	keyword1 += "【" + v.RealName + "--" + v.CompanyName + "】"
+	//}
+	//openIdList, e := models.GetWxOpenIdByMobileList(mobile)
+	//if e != nil {
+	//	err = errors.New("GetSellerByAdminId, Err: " + e.Error())
+	//	return
+	//}
+	//first = "【" + activityInfo.ResearchTheme + "】已有10人预报名"
+	//keyword3 = "-"
+	//keyword2 = "-"
+	//keyword4 = "【" + activityInfo.ResearchTheme + "】已有10人预报名"
+	//openIdArr := make([]string, 0)
+	//for _, v := range openIdList {
+	//	openIdArr = append(openIdArr, v.OpenId)
+	//}
+	//redirectUrl := utils.WX_MSG_PATH_ACTIVITY_SPECIAL_DETAIL + strconv.Itoa(activityId)
+	//sendInfo := new(SendWxTemplate)
+	//sendInfo.First = first
+	//sendInfo.Keyword1 = keyword1
+	//sendInfo.Keyword2 = keyword2
+	//sendInfo.Keyword3 = keyword3
+	//sendInfo.Keyword4 = keyword4
+	//sendInfo.Remark = remark
+	//sendInfo.TemplateId = utils.WxMsgTemplateIdAskMsgXzs
+	//sendInfo.RedirectUrl = redirectUrl
+	//sendInfo.RedirectTarget = 3
+	//sendInfo.Resource = strconv.Itoa(activityId)
+	//sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_ARTICLE_ADD
+	//sendInfo.OpenIdArr = openIdArr
+	//err = PublicSendTemplateMsg(sendInfo)
+	//if err != nil {
+	//	return
+	//}
+	return
+}