package services import ( "context" "fmt" "hongze/hongze_cygx/models" "hongze/hongze_cygx/utils" "time" ) //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) } }() //根据手机号分组获取列表以及数量 var condition string var pars []interface{} condition += ` AND s.create_time < ? ` pars = append(pars, time.Now().Format(utils.FormatDate)) listSpecial, err := models.GetActivityListSpecialGroupByMobile(condition, pars) 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(condition, pars) if err != nil { return err } //更改这些公司对应的关注关注数量 err = models.UpdateActivitySpecialSignupCompanyNumMulti(listSpecialByCompanyId) if err != nil { return err } fmt.Println("UpdateCygxActivitySpecialSignupNum end") return }