activity_special.go 1.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  1. package services
  2. import (
  3. "context"
  4. "fmt"
  5. "hongze/hongze_cygx/models"
  6. "hongze/hongze_cygx/utils"
  7. )
  8. //func init() {
  9. // UpdateCygxActivitySpecialSignupNum()
  10. //}
  11. //修改专项调研,用户与公司的参与数量
  12. func UpdateCygxActivitySpecialSignupNum(cont context.Context) (err error) {
  13. defer func() {
  14. if err != nil {
  15. fmt.Println(err)
  16. go utils.SendAlarmMsg("修改活动状态至进行中失败"+err.Error(), 2)
  17. go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "修改活动状态至进行中失败 ErrMsg:"+err.Error(), utils.EmailSendToUsers)
  18. }
  19. }()
  20. //根据手机号分组获取列表以及数量
  21. listSpecial, err := models.GetActivityListSpecialGroupByMobile()
  22. if err != nil {
  23. return err
  24. }
  25. var mapMobile []string
  26. for _, v := range listSpecial {
  27. mapMobile = append(mapMobile, v.Mobile)
  28. }
  29. //根据手机号获取这些用户的信息
  30. userList, err := models.GetWxUserByMobiles(mapMobile)
  31. if err != nil {
  32. return err
  33. }
  34. //更改这些手机对应的关注关注数量
  35. err = models.UpdateActivitySpecialSignupNumMulti(listSpecial)
  36. if err != nil {
  37. return err
  38. }
  39. //更改这些手机对应的公司ID
  40. err = models.UpdateActivitySpecialSignupCompanyIdMulti(userList)
  41. if err != nil {
  42. return err
  43. }
  44. //根据CompanyId分组获取列表以及数量
  45. listSpecialByCompanyId, err := models.GetActivityListSpecialGroupByCompanyId()
  46. if err != nil {
  47. return err
  48. }
  49. //更改这些公司对应的关注关注数量
  50. err = models.UpdateActivitySpecialSignupCompanyNumMulti(listSpecialByCompanyId)
  51. if err != nil {
  52. return err
  53. }
  54. fmt.Println("UpdateCygxActivitySpecialSignupNum end")
  55. return
  56. }