package services import ( "errors" "fmt" "hongze/hongze_clpt/models" "hongze/hongze_clpt/utils" "strconv" "time" ) // SendReviewTemplateMsgAdmin 提交审核时给王芳,汪洋发消息 func SendReviewTemplateMsgAdmin(specialId int) (err error) { defer func() { if err != nil { go utils.SendAlarmMsg("处理试用申请给王芳,汪洋发消息失败, ErrMsg: "+err.Error(), 3) } }() 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 } // 更新研选专栏 写入首页最新 cygx_resource_data 表 func UpdateYanxuanSpecialResourceData(sourceId int) { var err error defer func() { if err != nil { go utils.SendAlarmMsg(fmt.Sprint("更新研选专栏失败ourceId: ", sourceId), 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 } publishDate := time.Now().Format(utils.FormatDateTime) 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 } // 获取研选专栏用户信息 func GetYanxuanSpecialAuthorInfo(user *models.WxUserItem) (itemResp *models.SpecialAuthorCheckResp) { var err error defer func() { if err != nil { go utils.SendAlarmMsg(fmt.Sprint("获取研选专栏用户信息失败,GetYanxuanSpecialAuthorInfo Err ", err, "userId", user.UserId), 2) } }() itemResp = new(models.SpecialAuthorCheckResp) var condition string condition += ` AND a.status = 1 ` specialUser, e := models.GetYanxuanSpecialAuthor(user.UserId, user.UserId, condition) if e != nil && e.Error() != utils.ErrNoRow() { err = errors.New("GetYanxuanSpecialAuthor, Err: " + e.Error()) return } if specialUser != nil { itemResp.IsAuthor = true itemResp.SpecialColumnId = specialUser.Id itemResp.HeadImg = specialUser.HeadImg //如果昵称 、专栏名称、简介 都不为空就表示信息完善 if specialUser.SpecialName != "" && specialUser.Introduction != "" && specialUser.NickName != "" { itemResp.IsImproveInformation = true } } return } // 获取专栏用户最新的一篇文章信息 func GetBestNewYanxuanSpecialByUserId(userIds []int) (mapResp map[int]*models.CygxYanxuanSpecialCenterAuthorResp) { lenArr := len(userIds) if lenArr == 0 { return } var err error defer func() { if err != nil { fmt.Println(err) go utils.SendAlarmMsg(fmt.Sprint("获取研选专栏用户信息失败,GetBestNewYanxuanSpecialByUserId Err ", err, "userIds", userIds), 2) } }() var condition string var pars []interface{} condition += ` AND user_id IN (` + utils.GetOrmInReplace(lenArr) + `) AND status = 3 GROUP BY user_id ORDER BY publish_time DESC` pars = append(pars, userIds) list, e := models.GetYanxuanSpecialListBycondition(condition, pars, 0, lenArr) if e != nil && e.Error() != utils.ErrNoRow() { err = errors.New("GetYanxuanSpecialListBycondition, Err: " + e.Error()) return } mapResp = make(map[int]*models.CygxYanxuanSpecialCenterAuthorResp, 0) for _, v := range list { item := new(models.CygxYanxuanSpecialCenterAuthorResp) item.UserId = v.UserId item.Id = v.Id item.Title = v.Title item.PublishTime = v.PublishTime mapResp[v.UserId] = item } return }