12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364 |
- package services
- import (
- "context"
- "fmt"
- "hongze/hongze_cygx/models"
- "hongze/hongze_cygx/utils"
- )
- //func init() {
- // UpdateCygxActivitySpecialSignupNum()
- //}
- //修改专项调研,用户与公司的参与数量
- func UpdateCygxActivitySpecialSignupNum(cont context.Context) (err error) {
- defer func() {
- if err != nil {
- fmt.Println(err)
- go utils.SendAlarmMsg("修改活动状态至进行中失败"+err.Error(), 2)
- go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "修改活动状态至进行中失败 ErrMsg:"+err.Error(), utils.EmailSendToUsers)
- }
- }()
- //根据手机号分组获取列表以及数量
- listSpecial, err := models.GetActivityListSpecialGroupByMobile()
- if err != nil {
- return err
- }
- var mapMobile []string
- for _, v := range listSpecial {
- mapMobile = append(mapMobile, v.Mobile)
- }
- //根据手机号获取这些用户的信息
- userList, err := models.GetWxUserByMobiles(mapMobile)
- if err != nil {
- return err
- }
- //更改这些手机对应的关注关注数量
- err = models.UpdateActivitySpecialSignupNumMulti(listSpecial)
- if err != nil {
- return err
- }
- //更改这些手机对应的公司ID
- err = models.UpdateActivitySpecialSignupCompanyIdMulti(userList)
- if err != nil {
- return err
- }
- //根据CompanyId分组获取列表以及数量
- listSpecialByCompanyId, err := models.GetActivityListSpecialGroupByCompanyId()
- if err != nil {
- return err
- }
- //更改这些公司对应的关注关注数量
- err = models.UpdateActivitySpecialSignupCompanyNumMulti(listSpecialByCompanyId)
- if err != nil {
- return err
- }
- fmt.Println("UpdateCygxActivitySpecialSignupNum end")
- return
- }
|