wx_template_msg.go 1.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041
  1. package models
  2. import "github.com/beego/beego/v2/client/orm"
  3. type SendTemplateResponse struct {
  4. Errcode int `json:"errcode"`
  5. Errmsg string `json:"errmsg"`
  6. MsgID int `json:"msgid"`
  7. }
  8. type OpenIdList struct {
  9. OpenId string
  10. }
  11. func GetOpenIdList() (items []*OpenIdList, err error) {
  12. openIdstr := WxUsersGet()
  13. sql := `SELECT open_id FROM wx_user AS wu
  14. INNER JOIN company AS c ON c.company_id = wu.company_id
  15. WHERE wu.open_id IS NOT NULL AND c.type IN (1,2) `
  16. if openIdstr != "" {
  17. sql += ` AND open_id in (` + openIdstr + `) `
  18. }
  19. _, err = orm.NewOrm().Raw(sql).QueryRows(&items)
  20. return
  21. }
  22. func GetWxOpenIdList() (items []*OpenIdList, err error) {
  23. sql := `SELECT open_id FROM wx_user AS wu
  24. INNER JOIN company AS c ON c.company_id = wu.company_id
  25. WHERE open_id=? `
  26. openId := "oW3Gts7V3hj-sTAE1VDi0MhGlee8"
  27. _, err = orm.NewOrm().Raw(sql, openId).QueryRows(&items)
  28. return
  29. }
  30. func DeleteTemplateRecordByDate(date string) (err error) {
  31. sql := `DELETE FROM user_template_record WHERE create_time<? `
  32. o := orm.NewOrm()
  33. _, err = o.Raw(sql, date).Exec()
  34. return
  35. }