123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304 |
- package services
- import (
- "errors"
- "fmt"
- "hongze/hongze_cygx/models"
- "hongze/hongze_cygx/utils"
- "strconv"
- "strings"
- "time"
- )
- // 研选专栏有新内容审核通过时,给关注此专栏的客户发送模板消息
- func SendWxMsgSpecialFollow(specialId int) (err error) {
- defer func() {
- if err != nil {
- go utils.SendAlarmMsg(fmt.Sprint("研选专栏有新内容审核通过时,给关注此专栏的客户发送模板消息失败", specialId, ", specialId", err.Error()), 2)
- }
- }()
- var first string
- var keyword1 string
- var keyword2 string
- var keyword3 string
- var keyword4 string
- var remark string
- followers, e := models.GetYanxuanSpecialFollowUserById(specialId)
- if e != nil {
- err = errors.New("GetYanxuanSpecialFollowUserById, Err: " + e.Error())
- return
- }
- if len(followers) == 0 {
- return
- }
- specialItem, e := models.GetYanxuanSpecialItemById(specialId)
- if e != nil {
- err = errors.New("GetYanxuanSpecialFollowUserById, Err: " + e.Error())
- return
- }
- var allInUserId string
- for _, v := range followers {
- allInUserId += strconv.Itoa(v) + ","
- }
- allInUserId = strings.TrimRight(allInUserId, ",")
- userList, err := models.GetWxUserListByUserIds(allInUserId)
- if err != nil && err.Error() != utils.ErrNoRow() {
- return err
- }
- mobile := ``
- for _, v := range userList {
- mobile += v.Mobile + ","
- }
- mobile = strings.TrimRight(mobile, ",")
- openIdList, e := models.GetWxOpenIdByMobileList(mobile)
- if e != nil {
- err = errors.New("GetSellerByAdminId, Err: " + e.Error())
- return
- }
- if len(openIdList) == 0 {
- return
- }
- //first =
- keyword1 = "研选专栏:" + specialItem.SpecialName
- keyword2 = "发布了新内容,点击查看详情"
- keyword3 = "-"
- //keyword4 = "【" + activityInfo.ResearchTheme + "】已有10人预报名"
- openIdArr := make([]string, 0)
- for _, v := range openIdList {
- openIdArr = append(openIdArr, v.OpenId)
- }
- redirectUrl := ""
- redirectUrl = utils.WX_MSG_PATH_YX_SPECIAL_DETAIL + strconv.Itoa(specialId)
- 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(specialId)
- sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_ARTICLE_ADD
- sendInfo.OpenIdArr = openIdArr
- err = PublicSendTemplateMsg(sendInfo)
- if err != nil {
- return
- }
- return
- }
- // SendReviewTemplateMsgAdmin 提交审核时给王芳,汪洋发消息
- func SendReviewTemplateMsgAdmin(specialId int) (err error) {
- defer func() {
- if err != nil {
- go utils.SendAlarmMsg(fmt.Sprint("处理试用申请给王芳,汪洋发消息失败, specialId:", specialId, "ErrMsg", err.Error()), 2)
- }
- }()
- var configCode string
- //如果是研选的就推送给汪洋跟王芳,否则就推送给王芳
- configCode = utils.TPL_MSG_WANG_FANG_WANG_YANG
- cnf, e := models.GetConfigByCode(configCode)
- if e != nil {
- err = errors.New("GetConfigByCode, Err: " + e.Error() + configCode)
- return
- }
- openIdList, e := models.GetUserRecordListByMobile(4, cnf.ConfigValue)
- if e != nil && e.Error() != utils.ErrNoRow() {
- err = errors.New("GetUserRecordListByMobile, Err: " + e.Error() + cnf.ConfigValue)
- return err
- }
- specialItem, e := models.GetYanxuanSpecialItemById(specialId)
- if e != nil {
- err = errors.New("GetYanxuanSpecialFollowUserById, Err: " + e.Error())
- return
- }
- user, e := models.GetWxUserItemByUserId(specialItem.UserId)
- if e != nil {
- err = errors.New("GetWxUserItemByUserId, Err: " + e.Error())
- return err
- }
- var keyword1 string
- var keyword2 string
- var keyword3 string
- var keyword4 string
- var remark string
- keyword1 = specialItem.RealName + "【" + user.CompanyName + "】"
- keyword2 = user.Mobile
- keyword3 = time.Now().Format(utils.FormatDateTime)
- keyword4 = "研选专栏提交了内容待审核"
- openIdArr := make([]string, 0)
- for _, v := range openIdList {
- openIdArr = append(openIdArr, v.OpenId)
- }
- redirectUrl := ""
- redirectUrl = utils.WX_MSG_PATH_YX_SPECIAL_ENABLE_DETAIL + strconv.Itoa(specialId)
- sendInfo := new(SendWxTemplate)
- 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(specialId)
- sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_ARTICLE_ADD
- sendInfo.OpenIdArr = openIdArr
- err = PublicSendTemplateMsg(sendInfo)
- if err != nil {
- return
- }
- return
- }
- // 研选专栏审核完成时,给提交人发送模板消息
- func SendWxMsgSpecialAuthor(specialId, status int) (err error) {
- defer func() {
- if err != nil {
- go utils.SendAlarmMsg(fmt.Sprint("研选专栏审核完成时,给提交人发送模板消息", specialId, ", specialId", err.Error()), 2)
- }
- }()
- var first string
- var keyword1 string
- var keyword2 string
- var keyword3 string
- var keyword4 string
- var remark string
- var redirectUrl string
- specialItem, e := models.GetYanxuanSpecialItemById(specialId)
- if e != nil {
- err = errors.New("GetYanxuanSpecialFollowUserById, Err: " + e.Error())
- return
- }
- user, e := models.GetWxUserItemByUserId(specialItem.UserId)
- if e != nil {
- err = errors.New("GetWxUserItemByUserId, Err: " + e.Error())
- return err
- }
- openIdList, err := models.GetUserRecordListByMobile(4, user.Mobile)
- if err != nil && err.Error() != utils.ErrNoRow() {
- return err
- }
- keyword1 = "研选专栏内容审核"
- if status == 1 {
- keyword2 = "已通过审核,点击查看详情"
- redirectUrl = utils.WX_MSG_PATH_YX_SPECIAL_DETAIL + strconv.Itoa(specialId)
- } else {
- keyword2 = "未通过审核,点击查看驳回原因"
- redirectUrl = utils.WX_MSG_PATH_YX_SPECIAL_CENTER
- }
- keyword3 = "-"
- openIdArr := make([]string, 0)
- for _, v := range openIdList {
- openIdArr = append(openIdArr, v.OpenId)
- }
- sendInfo := new(SendWxTemplate)
- sendInfo.First = first
- sendInfo.Keyword1 = keyword1
- sendInfo.Keyword2 = keyword2
- sendInfo.Keyword3 = keyword3
- sendInfo.Keyword4 = keyword4
- sendInfo.Remark = remark
- sendInfo.TemplateId = utils.WxMsgTemplateIdArticleUserRemind
- sendInfo.RedirectUrl = redirectUrl
- sendInfo.RedirectTarget = 3
- sendInfo.Resource = strconv.Itoa(specialId)
- sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_ARTICLE_ADD
- sendInfo.OpenIdArr = openIdArr
- err = PublicSendTemplateMsg(sendInfo)
- if err != nil {
- return
- }
- return
- }
- //func init() {
- //
- // var condition string
- // var pars []interface{}
- //
- // condition = " AND a.user_id = 103354 "
- // list, tmpErr := models.GetYanxuanSpecialList(0, condition, pars)
- //
- // fmt.Println(len(list))
- // fmt.Println(tmpErr)
- //
- // for _, v := range list {
- // fmt.Println(v.Id)
- // EsAddYanxuanSpecial(v.Id)
- // }
- //}
- // 更新研选专栏 写入首页最新 cygx_resource_data 表
- func UpdateYanxuanSpecialResourceData(sourceId int) {
- var err error
- defer func() {
- if err != nil {
- go utils.SendAlarmMsg(fmt.Sprint("更新研选专栏失败sourceId: ", sourceId, "ErrMsg", err.Error()), 2)
- }
- }()
- var source = utils.CYGX_OBJ_YANXUANSPECIAL
- var condition string
- var pars []interface{}
- condition = ` AND status = 3 AND id = ? `
- pars = append(pars, sourceId)
- total, e := models.GetCygxYanxuanSpecialCount(condition, pars)
- if e != nil {
- err = errors.New("GetCygxYanxuanSpecialCount, Err: " + e.Error())
- return
- }
- //如果取消发布了就做删除处理
- if total == 0 {
- e = models.DeleteResourceData(sourceId, source)
- if e != nil {
- err = errors.New("DeleteResourceData, Err: " + e.Error())
- return
- }
- } else {
- //判断是否存在,如果不存在就新增,存在就更新
- totalData, e := models.GetCygxResourceDataBySourceAndIdCount(sourceId, source)
- if e != nil {
- err = errors.New("GetCygxReportSelectionBySourceAndId, Err: " + e.Error())
- return
- }
- detail, e := models.GetYanxuanSpecialBySpecialId(sourceId)
- if e != nil {
- err = errors.New("GetYanxuanSpecialBySpecialId, Err: " + e.Error())
- return
- }
- publishDate := detail.PublishTime
- item := new(models.CygxResourceData)
- item.SourceId = sourceId
- item.Source = source
- item.PublishDate = publishDate
- item.CreateTime = time.Now()
- if totalData == 0 {
- _, e := models.AddCygxResourceData(item)
- if e != nil {
- err = errors.New("AddCygxResourceData, Err: " + e.Error())
- return
- }
- } else {
- e = models.UpdateResourceDataByItem(item)
- if e != nil {
- err = errors.New("UpdateResourceDataByItem, Err: " + e.Error())
- return
- }
- }
- }
- return
- }
|